pub fn adapt_unbounded(
        schema: SchemaRef,
        rx: UnboundedReceiver<ArrowResult<RecordBatch>>,
        join_handle: Option<Arc<AutoAbortJoinHandle<()>>>,
    ) -> SendableRecordBatchStream {
        let inner = UnboundedReceiverStream::new(rx);
        Box::pin(Self {
            schema,
            inner,
            join_handle,
        })
    }
/// Create a new stream which wraps the `inner` unbounded channel which
/// produces [`RecordBatch`]es that each have the specified schema
///
/// Not called `new` because it returns a pinned reference rather than the
/// object itself.
Create a new stream which wraps the `inner` unbounded channel which
produces [`RecordBatch`]es that each have the specified schema

Not called `new` because it returns a pinned reference rather than the
object itself.
Create a new stream which wraps the ` inner ` unbounded channel which produces [ ` RecordBatch ` ] es that each have the specified schema Not called ` new ` because it returns a pinned reference rather than the object itself .
pub fn adapt_unbounded(
        schema: SchemaRef,
        rx: UnboundedReceiver<ArrowResult<RecordBatch>>,
        join_handle: Option<Arc<AutoAbortJoinHandle<()>>>,
    ) -> SendableRecordBatchStream {
        let inner = UnboundedReceiverStream::new(rx);
        Box::pin(Self {
            schema,
            inner,
            join_handle,
        })
    }
pub fn adapt_unbounded ( schema : SchemaRef , rx : UnboundedReceiver < ArrowResult < RecordBatch > > , join_handle : Option < Arc < AutoAbortJoinHandle < ( ) > > > , ) -> SendableRecordBatchStream { let inner = UnboundedReceiverStream :: new ( rx ) ; Box :: pin ( Self { schema , inner , join_handle , } ) }
Create a new stream which wraps the `inner` unbounded channel which
produces [`RecordBatch`]es that each have the specified schema
Create a new stream which wraps the ` inner ` unbounded channel which produces [ ` RecordBatch ` ] es that each have the specified schema
schema
SchemaRef
rx
UnboundedReceiver<ArrowResult<RecordBatch>>
join_handle
Option<Arc<AutoAbortJoinHandle<()>>>
schema
SchemaRef
rx
UnboundedReceiver<ArrowResult<RecordBatch>>
join_handle
Option<Arc<AutoAbortJoinHandle<()>>>