arrow.stream_decoder

Module for [StreamDecoder] class

class StreamDecoder StreamDecoderGidBuilder StreamDecoderGidBuilderImpl

Types 3

classStreamDecoder : gobject.object.ObjectWrap

Methods

GType _getGType()

GType _gType() @property

StreamDecoder self()Returns `this`, for use in `with` statements.

StreamDecoderGidBuilder builder()Get builder for [arrow.stream_decoder.StreamDecoder] Returns: New builder object

arrow.stream_listener.StreamListener listener() @propertyGet `listener` property. Returns: A listener that receives decoded events.

bool consumeBuffer(arrow.buffer.Buffer buffer)Feed data to the decoder as a #GArrowBuffer.

bool consumeBytes(glib.bytes.Bytes bytes)Feed data to the decoder as a raw data.

size_t getNextRequiredSize()This method is provided for users who want to optimize performance. Normal users don't need to use this method.

arrow.schema.Schema getSchema()

bool reset()Reset the internal status.

Constructors

this(void * ptr, Flag!"Take" take)

this(arrow.stream_listener.StreamListener listener, arrow.read_options.ReadOptions options = null)

classStreamDecoderGidBuilderImpl(T) : gobject.object.ObjectWrapGidBuilderImpl!T

Methods

T decoder(void * propval)

T listener(arrow.stream_listener.StreamListener propval)Set `listener` property. Params: propval = A listener that receives decoded events. Returns: Builder instance for fluent chaining

classStreamDecoderGidBuilder : StreamDecoderGidBuilderImpl!StreamDecoderGidBuilder

Fluent builder for [arrow.stream_decoder.StreamDecoder]

Methods

StreamDecoder build()