source_reader_event_to_chunk_stream

risingwave_stream::executor::source

Function source_reader_event_to_chunk_stream 

Source 
pub fn source_reader_event_to_chunk_stream(
    stream: BoxSourceReaderEventStream,
) -> impl Stream<Item = Result<StreamChunk, ConnectorError>>