pub(super) trait ChanReceiver: Send {
// Required method
async fn recv(&mut self) -> SharedResult<Option<DataChunkInChannel>>;
}Required Methods§
sourceasync fn recv(&mut self) -> SharedResult<Option<DataChunkInChannel>>
async fn recv(&mut self) -> SharedResult<Option<DataChunkInChannel>>
Returns None if there’s no more data to read.
Otherwise it will wait until there’s data.
Object Safety§
This trait is not object safe.