pyarrow.MessageReader¶

class pyarrow.MessageReader¶

Bases: object

Interface for reading Message objects from some source (like an InputStream)

__init__()¶: Initialize self. See help(type(self)) for accurate signature.

Methods

`open_stream`(source)
`read_next_message`(self)	Read next Message from the stream.

read_next_message(self)¶: Read next Message from the stream. Raises StopIteration at end of stream