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

Apache.Arrow.Ipc.ArrowReaderImplementation

abstract class ArrowReaderImplementation : IDisposable
public Schema Schema { get; }

protected RecordBatch CreateArrowObjectFromMessage(Message message, ByteBuffer bodyByteBuffer, IMemoryOwner<byte> memoryOwner)

public void Dispose()

protected virtual void Dispose(bool disposing)

public abstract RecordBatch ReadNextRecordBatch()

public abstract ValueTask<RecordBatch> ReadNextRecordBatchAsync(CancellationToken cancellationToken)

public abstract void ReadSchema()

public abstract ValueTask ReadSchemaAsync(CancellationToken cancellationToken)