arrow.stream_listener

Module for [StreamListener] class

class StreamListener StreamListenerGidBuilder StreamListenerGidBuilderImpl

Types 3

classStreamListener : gobject.object.ObjectWrap
Methods
GType _getGType()
GType _gType() @property
StreamListener self()Returns `this`, for use in `with` statements.
StreamListenerGidBuilder builder()Get builder for [arrow.stream_listener.StreamListener] Returns: New builder object
bool onEos()Processes an EOS event. Returns: true on success, false on error. Throws: [ErrorWrap]
bool onRecordBatchDecoded(arrow.record_batch.RecordBatch recordBatch, string[string] metadata = null)Processes a decoded record batch.
bool onSchemaDecoded(arrow.schema.Schema schema, arrow.schema.Schema filteredSchema)Processes a decoded schema.
Constructors
this(void * ptr, Flag!"Take" take)
classStreamListenerGidBuilderImpl(T) : gobject.object.ObjectWrapGidBuilderImpl!T
classStreamListenerGidBuilder : StreamListenerGidBuilderImpl!StreamListenerGidBuilder

Fluent builder for [arrow.stream_listener.StreamListener]

Methods
StreamListener build()