namespace Apache.Arrow.Ipc { public class ArrowStreamReader : IArrowReader, IArrowArrayStream, IDisposable { public Schema Schema { get; } public ArrowStreamReader(Stream stream); public ArrowStreamReader(Stream stream, MemoryAllocator allocator); public ArrowStreamReader(Stream stream, ICompressionCodecFactory compressionCodecFactory); public ArrowStreamReader(Stream stream, bool leaveOpen); public ArrowStreamReader(Stream stream, MemoryAllocator allocator, bool leaveOpen); public ArrowStreamReader(Stream stream, ICompressionCodecFactory compressionCodecFactory, bool leaveOpen); public ArrowStreamReader(Stream stream, MemoryAllocator allocator, ICompressionCodecFactory compressionCodecFactory, bool leaveOpen); public ArrowStreamReader(ArrowContext context, Stream stream, bool leaveOpen = false); public ArrowStreamReader(ReadOnlyMemory<byte> buffer); public ArrowStreamReader(ReadOnlyMemory<byte> buffer, ICompressionCodecFactory compressionCodecFactory); public ArrowStreamReader(ArrowContext context, ReadOnlyMemory<byte> buffer); public void Dispose(); protected virtual void Dispose(bool disposing); public ValueTask<Schema> GetSchema(CancellationToken cancellationToken = default(CancellationToken)); public ValueTask<RecordBatch> ReadNextRecordBatchAsync(CancellationToken cancellationToken = default(CancellationToken)); public RecordBatch ReadNextRecordBatch(); } }