risingwave_
connector
2.4.0-alpha
Source
Chunk
Stream
Implementors
In risingwave_
connector::
source::
base
risingwave_connector
::
source
::
base
Trait
SourceChunkStream
Copy item path
Source
pub trait SourceChunkStream: Stream<Item =
ConnectorResult
<StreamChunk>> +
Send
+ 'static { }
Implementors
§
Source
§
impl<T>
SourceChunkStream
for T
where T: Stream<Item =
ConnectorResult
<StreamChunk>> +
Send
+ 'static,