Struct crossbus::message::MStreaming

pub struct MStreaming<S: CoreStream> { /* private fields */ }

streaming a batch of message and send them to Actor::action

Implementations

impl<S: CoreStream> MStreaming<S>

pub fn new(stream: S) -> Self

create an instance

pub fn handle(&self) -> Handle

get the handle

pub fn state(&self) -> MStreamState

get the state

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

set the state

Trait Implementations

impl<A, S> Future<A> for MStreaming<S>where A: Actor<Message = S::Item> + MStream<S::Item>, S: CoreStream + 'static, S::Item: Message,

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, S: CoreStream> Unpin for MStreaming<S>where __Origin<'__pin, S>: Unpin,