File tree Expand file tree Collapse file tree
crates/core/src/kernel/snapshot Expand file tree Collapse file tree Original file line number Diff line number Diff line change 22//!
33use arrow:: { datatypes:: SchemaRef , record_batch:: RecordBatch } ;
44use futures:: stream:: BoxStream ;
5- use futures:: { Future , Stream , StreamExt } ;
5+ use futures:: { Stream , StreamExt } ;
66use std:: pin:: Pin ;
77use tokio:: sync:: mpsc:: { Receiver , Sender } ;
88use tokio:: task:: JoinSet ;
@@ -57,7 +57,7 @@ pub type SendableRBStream = Pin<Box<dyn Stream<Item = DeltaResult<RecordBatch>>
5757///
5858/// Note that this is similar to [`ReceiverStream` from tokio-stream], with the differences being:
5959///
60- /// 1. Methods to bound and "detach" tasks (`spawn()` and `spawn_blocking()`).
60+ /// 1. Methods to bound and "detach" tasks (`spawn_blocking()`).
6161///
6262/// 2. Propagates panics, whereas the `tokio` version doesn't propagate panics to the receiver.
6363///
@@ -87,17 +87,6 @@ impl<O: Send + 'static> ReceiverStreamBuilder<O> {
8787 self . tx . clone ( )
8888 }
8989
90- /// Spawn task that will be aborted if this builder (or the stream
91- /// built from it) are dropped
92- #[ allow( unused) ]
93- pub fn spawn < F > ( & mut self , task : F )
94- where
95- F : Future < Output = DeltaResult < ( ) > > ,
96- F : Send + ' static ,
97- {
98- self . join_set . spawn ( task) ;
99- }
100-
10190 /// Spawn a blocking task that will be aborted if this builder (or the stream
10291 /// built from it) are dropped.
10392 ///
You can’t perform that action at this time.
0 commit comments