Struct WebSocketSession

pub struct WebSocketSession {
    microscope_id: Uuid,
    hb: Instant,
    server_addr: Addr<Server>,
    jwt_token: JwtToken,
}

Session, needs for each client connection

Fields

microscope_id: Uuid

ID of the microscope to which the user is connected

hb: Instant

Time of the last session update (updated on any message received by the user’s cell)

server_addr: Addr<Server>

Address for sending messages via websocket

jwt_token: JwtToken

User token

Implementations

impl WebSocketSession

async fn new( microscope_id: Uuid, server_addr: Addr<Server>, jwt_token: JwtToken, ) -> Result<Self, String>

fn send_heartbeat(&self, ctx: &mut <Self as Actor>::Context)

Check connection viability, disconnect if client does not respond for more than CLIENT_TIMEOUT

Trait Implementations

impl Actor for WebSocketSession

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

Called after a websocket connection has started and send data about connection to server

type Context = WebsocketContext<WebSocketSession>

Actor execution context type

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 Clone for WebSocketSession

fn clone(&self) -> WebSocketSession

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Handler<FromMicroscopeEvent> for WebSocketSession

fn handle(&mut self, msg: FromMicroscopeEvent, ctx: &mut Self::Context)

An event handler for sending FromMicroscopeMessage over a websocket connection

type Result = ()

The type of value that this handler will return.

impl Handler<FromUserEvent> for WebSocketSession

fn handle(&mut self, msg: FromUserEvent, ctx: &mut Self::Context)

An event handler for sending FromUserMessage over a websocket connection

type Result = ()

The type of value that this handler will return.

impl Handler<PictureUpdateEvent> for WebSocketSession

fn handle(&mut self, msg: PictureUpdateEvent, ctx: &mut Self::Context)

An event handler for sending PictureUpdateEvent over a websocket connection

type Result = ()

The type of value that this handler will return.

impl Handler<ToMicroscopeEvent> for WebSocketSession

fn handle(&mut self, msg: ToMicroscopeEvent, ctx: &mut Self::Context)

An event handler for sending ToMicroscopeMessage over a websocket connection

type Result = ()

The type of value that this handler will return.

impl StreamHandler<Result<Message, ProtocolError>> for WebSocketSession

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

The initial handler for all events coming to the websocket, sends parsed text messages to the server

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.