Struct WebsocketProxy

pub struct WebsocketProxy<S>
where
    S: Unpin + Sink<Message>,
{ /* private fields */ }

WebsocketProxy proxies an incoming websocket connection to another websocket, connected via awc.

Trait Implementations

impl<S> Actor for WebsocketProxy<S>

where S: Unpin + 'static + Sink<Message>,

type Context = WebsocketContext<WebsocketProxy<S>>

Actor execution context type

fn started(&mut self, ctx: &mut Self::Context)

Called when an actor gets polled the first time.

fn stopping(&mut self, ctx: &mut Self::Context) -> Running

Called after an actor is in Actor::Stopping state.

fn stopped(&mut self, ctx: &mut Self::Context)

Called after an actor is stopped.

impl<S> StreamHandler<Result<Frame, ProtocolError>> for WebsocketProxy<S>

where S: Unpin + Sink<Message> + 'static,

fn handle( &mut self, item: Result<Frame, ProtocolError>, ctx: &mut Self::Context, )

Called for every message emitted by the stream.

fn started(&mut self, ctx: &mut Self::Context)

Called when stream emits first item.

fn finished(&mut self, ctx: &mut Self::Context)

Called when stream finishes.

fn add_stream<S>(stream: S, ctx: &mut Self::Context) -> SpawnHandle

where S: Stream + 'static, Self: StreamHandler<<S as Stream>::Item>, Self::Context: AsyncContext<Self>,

Register a Stream to the actor context.

impl<S> StreamHandler<Result<Message, ProtocolError>> for WebsocketProxy<S>

where S: Unpin + Sink<Message> + 'static,

fn handle( &mut self, item: Result<Message, ProtocolError>, ctx: &mut Self::Context, )

Called for every message emitted by the stream.

fn started(&mut self, ctx: &mut Self::Context)

Called when stream emits first item.

fn finished(&mut self, ctx: &mut Self::Context)

Called when stream finishes.

fn add_stream<S>(stream: S, ctx: &mut Self::Context) -> SpawnHandle

where S: Stream + 'static, Self: StreamHandler<<S as Stream>::Item>, Self::Context: AsyncContext<Self>,

Register a Stream to the actor context.

impl<S> WriteHandler<ProtocolError> for WebsocketProxy<S>

where S: Unpin + 'static + Sink<Message>,

fn error(&mut self, err: ProtocolError, ctx: &mut Self::Context) -> Running

Called when the writer emits error.

fn finished(&mut self, ctx: &mut Self::Context)

Called when the writer finishes.