MCPcopy Create free account
hub / github.com/apache/arrow-rs / queue_messages

Method queue_messages

arrow-flight/src/encode.rs:340–344  ·  view source on GitHub ↗

Place the `FlightData` in the queue to send

(&mut self, datas: impl IntoIterator<Item = FlightData>)

Source from the content-addressed store, hash-verified

338
339 /// Place the `FlightData` in the queue to send
340 fn queue_messages(&mut self, datas: impl IntoIterator<Item = FlightData>) {
341 for data in datas {
342 self.queue_message(data)
343 }
344 }
345
346 /// Encodes schema as a [`FlightData`] in self.queue.
347 /// Updates `self.schema` and returns the new schema

Callers 1

encode_batchMethod · 0.80

Calls 1

queue_messageMethod · 0.80

Tested by

no test coverage detected