InputStream

class InputStream : InputStream , File , Readable {

}

Members

Functions

advance bool advance(long nBytes)
align_ bool align_(int alignment)
readRecordBatch arrow.record_batch.RecordBatch readRecordBatch(arrow.schema.Schema schema, arrow.read_options.ReadOptions options)
readTensor arrow.tensor.Tensor readTensor()

Mixed In Members

From `mixin FileT!()`

close bool close()
getMode arrow.types.FileMode getMode()
isClosed bool isClosed()
tell long tell()

From `mixin ReadableT!()`

read arrow.buffer.Buffer read(long nBytes)
readBytes glib.bytes.Bytes readBytes(long nBytes)

Inherited Members

From InputStream

clearPending void clearPending(): Clears the pending flag on stream.
close bool close(gio.cancellable.Cancellable cancellable): Closes the stream, releasing resources related to it.
closeAsync void closeAsync(int ioPriority, gio.cancellable.Cancellable cancellable, gio.types.AsyncReadyCallback callback): Requests an asynchronous closes of the stream, releasing resources related to it. When the operation is finished callback will be called. You can then call gio.input_stream.InputStream.closeFinish to get the result of the operation.
closeFinish bool closeFinish(gio.async_result.AsyncResult result): Finishes closing a stream asynchronously, started from gio.input_stream.InputStream.closeAsync.
hasPending bool hasPending(): Checks if an input stream has pending actions.
isClosed bool isClosed(): Checks if an input stream is closed.
read ptrdiff_t read(ubyte[] buffer, gio.cancellable.Cancellable cancellable): Tries to read count bytes from the stream into the buffer starting at buffer. Will block during this read.
readAll bool readAll(ubyte[] buffer, size_t bytesRead, gio.cancellable.Cancellable cancellable): Tries to read count bytes from the stream into the buffer starting at buffer. Will block during this read.
readAllAsync void readAllAsync(ubyte[] buffer, int ioPriority, gio.cancellable.Cancellable cancellable, gio.types.AsyncReadyCallback callback): Request an asynchronous read of count bytes from the stream into the buffer starting at buffer.
readAllFinish bool readAllFinish(gio.async_result.AsyncResult result, size_t bytesRead): Finishes an asynchronous stream read operation started with gio.input_stream.InputStream.readAllAsync.
readAsync void readAsync(ubyte[] buffer, int ioPriority, gio.cancellable.Cancellable cancellable, gio.types.AsyncReadyCallback callback): Request an asynchronous read of count bytes from the stream into the buffer starting at buffer. When the operation is finished callback will be called. You can then call gio.input_stream.InputStream.readFinish to get the result of the operation.
readBytes glib.bytes.Bytes readBytes(size_t count, gio.cancellable.Cancellable cancellable): Like gio.input_stream.InputStream.read, this tries to read count bytes from the stream in a blocking fashion. However, rather than reading into a user-supplied buffer, this will create a new #GBytes containing the data that was read. This may be easier to use from language bindings.
readBytesAsync void readBytesAsync(size_t count, int ioPriority, gio.cancellable.Cancellable cancellable, gio.types.AsyncReadyCallback callback): Request an asynchronous read of count bytes from the stream into a new #GBytes. When the operation is finished callback will be called. You can then call gio.input_stream.InputStream.readBytesFinish to get the result of the operation.
readBytesFinish glib.bytes.Bytes readBytesFinish(gio.async_result.AsyncResult result): Finishes an asynchronous stream read-into-#GBytes operation.
readFinish ptrdiff_t readFinish(gio.async_result.AsyncResult result): Finishes an asynchronous stream read operation.
setPending bool setPending(): Sets stream to have actions pending. If the pending flag is already set or stream is closed, it will return false and set error.
skip ptrdiff_t skip(size_t count, gio.cancellable.Cancellable cancellable): Tries to skip count bytes from the stream. Will block during the operation.
skipAsync void skipAsync(size_t count, int ioPriority, gio.cancellable.Cancellable cancellable, gio.types.AsyncReadyCallback callback): Request an asynchronous skip of count bytes from the stream. When the operation is finished callback will be called. You can then call gio.input_stream.InputStream.skipFinish to get the result of the operation.
skipFinish ptrdiff_t skipFinish(gio.async_result.AsyncResult result): Finishes a stream skip operation.