namespace Apache.Arrow.Ipc { internal class ArrowStreamReaderImplementation : ArrowReaderImplementation { public Stream BaseStream { get; } public ArrowStreamReaderImplementation(Stream stream, MemoryAllocator allocator, ICompressionCodecFactory compressionCodecFactory, bool leaveOpen); public ArrowStreamReaderImplementation(Stream stream, MemoryAllocator allocator, ICompressionCodecFactory compressionCodecFactory, bool leaveOpen, ExtensionTypeRegistry extensionRegistry); protected ValueTask<RecordBatch> ReadRecordBatchAsync(CancellationToken cancellationToken = default(CancellationToken)); protected ValueTask<ReadResult> ReadMessageAsync(CancellationToken cancellationToken); protected RecordBatch ReadRecordBatch(); protected ReadResult ReadMessage(); protected IMemoryOwner<byte> AllocateMessageBodyBuffer(int bodyLength); } }