namespace Apache.Arrow.Ipc { internal abstract class ArrowReaderImplementation : IDisposable { public Schema Schema { get; } public void Dispose(); protected virtual void Dispose(bool disposing); public abstract ValueTask<Schema> ReadSchemaAsync(CancellationToken cancellationToken); public abstract void ReadSchema(); public abstract ValueTask<RecordBatch> ReadNextRecordBatchAsync(CancellationToken cancellationToken); public abstract RecordBatch ReadNextRecordBatch(); protected RecordBatch CreateArrowObjectFromMessage(Message message, ByteBuffer bodyByteBuffer, IMemoryOwner<byte> memoryOwner); } }