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

Apache.Arrow.Ipc.ArrowStreamReaderImplementation

class ArrowStreamReaderImplementation : ArrowReaderImplementation
public Stream BaseStream { get; }

public ArrowStreamReaderImplementation(Stream stream, MemoryAllocator allocator, ICompressionCodecFactory compressionCodecFactory, bool leaveOpen)

protected ReadResult ReadMessage()

protected ValueTask<ReadResult> ReadMessageAsync(CancellationToken cancellationToken)

protected RecordBatch ReadRecordBatch()

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