Struct crossbus::stream::Streaming

pub struct Streaming<A: Actor, S: Stream> { /* private fields */ }

streaming a batch of items and send them to Stream::action

Implementations

impl<A: Actor, S: Stream> Streaming<A, S>

pub fn new(stream: S) -> Self

pub fn handle(&self) -> Handle

get the handle

pub fn state(&self) -> StreamState

get the state

pub fn set_state(&mut self, state: StreamState)

set the state

Trait Implementations

impl<A, S> Future<A> for Streaming<A, S>where S: Stream + 'static, A: Actor + Stream<S::Item>,

type Output = ()

the returned type of value when the future polled successfully

fn poll( self: Pin<&mut Self>, act: &mut A, ctx: &mut Context<A>, cx: &mut CoreContext<'_> ) -> Poll<Self::Output>

fn downcast_ref(&self) -> Option<&dyn Any>

fn downcast_mut(self: Pin<&mut Self>) -> Option<Pin<&mut dyn Any>>

impl<'__pin, A: Actor, S: Stream> Unpin for Streaming<A, S>where __Origin<'__pin, A, S>: Unpin,