Enum holly::actor::State

pub enum State<A, T> {
    Ready(A),
    Stream(A, Box<dyn Stream<Item = T, Error = Void> + Send>),
    Close(A),
    Done,
}

The processing state an actor transitions to after receiving a message.

Variants

Ready(A)

The actor is ready to accept more messages.

Stream(A, Box<dyn Stream<Item = T, Error = Void> + Send>)

The actor is ready to accept more messages and wants to add another stream of messages to its mailbox.

Close(A)

The actor wants to close its mailbox.

This will prevent other actors from sending any more messages to this actor's address. All enqueued messages will still be processed. Note that it is the actor's responsibility to close streams added via State::Stream.

Done

The actor has finished processing (terminal state).

Trait Implementations

impl<A, T> Into<State<A, T, ()>> for State<A, T>

fn into(self) -> State<A, T, ()>

Performs the conversion.