Struct rotor_http::server::Stream

pub struct Stream<P> where
    P: Protocol,  { /* fields omitted */ }

A main stream state machine abstaction

You may use the Stream directly. But it's recommented to either use Persistent for client connections or Accept for server-side connection processing.

Methods

impl<P> Stream<P> where
    P: Protocol, 

fn transport(&mut self) -> Transport<<P as Protocol>::Socket>

Get a Transport object for the stream

This method is only useful if you want to manipulate buffers externally (like pushing to the buffer from another thread). Just be sure to wake up state machine after manipulating buffers.

fn new(
    sock: <P as Protocol>::Socket,
    seed: <P as Protocol>::Seed,
    scope: &mut Scope<<P as Protocol>::Context>
) -> Response<Stream<P>, Void>

fn connected(
    sock: <P as Protocol>::Socket,
    seed: <P as Protocol>::Seed,
    scope: &mut Scope<<P as Protocol>::Context>
) -> Response<Stream<P>, Void>

Trait Implementations

impl<P> Accepted for Stream<P> where
    P: Protocol,
    <P as Protocol>::Seed: Clone, 

type Seed = <P as Protocol>::Seed

type Socket = <P as Protocol>::Socket

fn accepted(
    sock: <P as Protocol>::Socket,
    seed: <P as Protocol>::Seed,
    scope: &mut Scope<<Stream<P> as Machine>::Context>
) -> Response<Stream<P>, Void>

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

type Context = <P as Protocol>::Context

type Seed = Void

fn create(
    void: Void,
    _scope: &mut Scope<<Stream<P> as Machine>::Context>
) -> Response<Stream<P>, Void>

fn ready(
    self,
    events: EventSet,
    scope: &mut Scope<<Stream<P> as Machine>::Context>
) -> Response<Stream<P>, <Stream<P> as Machine>::Seed>

fn spawned(
    self,
    _scope: &mut Scope<<Stream<P> as Machine>::Context>
) -> Response<Stream<P>, <Stream<P> as Machine>::Seed>

fn timeout(
    self,
    scope: &mut Scope<<Stream<P> as Machine>::Context>
) -> Response<Stream<P>, <Stream<P> as Machine>::Seed>

fn wakeup(
    self,
    scope: &mut Scope<<Stream<P> as Machine>::Context>
) -> Response<Stream<P>, <Stream<P> as Machine>::Seed>

impl<P> Debug for Stream<P> where
    P: Protocol + Debug,
    <P as Protocol>::Socket: Debug, 

fn fmt(&self, __arg_0: &mut Formatter) -> Result<(), Error>

Formats the value using the given formatter.