<PackageReference Include="Apache.Arrow" Version="23.0.0" />

Apache.Arrow.Ipc.ArrowStreamReaderImplementation

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 IMemoryOwner<byte> AllocateMessageBodyBuffer(int bodyLength)

protected ReadResult ReadMessage()

protected ValueTask<ReadResult> ReadMessageAsync(CancellationToken cancellationToken)

protected RecordBatch ReadRecordBatch()

protected ValueTask<RecordBatch> ReadRecordBatchAsync(CancellationToken cancellationToken = default)