Struct rotor_stream::Stream

pub struct Stream<P: Protocol> {
    // some fields omitted
}

Methods

impl<P: Protocol> Stream<P>

fn new(sock: P::Socket, seed: P::Seed, scope: &mut Scope<P::Context>) -> Result<Self, Box<Error>>

Trait Implementations

impl<P: Protocol> Accepted<P::Socket> for Stream<P> where P: Protocol<Seed=()>

fn accepted(sock: P::Socket, scope: &mut Scope<Self::Context>) -> Result<Self, Box<Error>>

impl<P: Protocol> Machine for Stream<P>

type Context = P::Context

Context type for the state machine

type Seed = Void

Seed is piece of data that is needed to initialize the machine

fn create(void: Void, _scope: &mut Scope<Self::Context>) -> Result<Self, Box<Error>>

Create a machine from some data

fn ready(self, _events: EventSet, scope: &mut Scope<Self::Context>) -> Response<Self, Self::Seed>

Socket readiness notification

fn spawned(self, _scope: &mut Scope<Self::Context>) -> Response<Self, Self::Seed>

Called after spawn event

fn timeout(self, scope: &mut Scope<Self::Context>) -> Response<Self, Self::Seed>

Timeout happened

fn wakeup(self, scope: &mut Scope<Self::Context>) -> Response<Self, Self::Seed>

Message received

fn spawn_error(self, _scope: &mut Scope<Self::Context>, error: SpawnError<Self::Seed>) -> Option<Self>

Called instead of spawned, if there is no slab space