Struct Session

pub struct Session {
    pub id: Uuid,
    pub heartbeat: bool,
    /* private fields */
}

会话，每创建一个连接，生成一个会话

Fields

id: Uuid

heartbeat: bool

Implementations

impl Session

pub fn new( socket_config: Arc<SocketConfig>, session_store: Arc<RwLock<SessionStore>>, ) -> Self

pub fn get_receiver(&self) -> Receiver<MessageType>

注册消息处理逻辑

Trait Implementations

impl Actor for Session

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

会话创建后

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

会话将要断开时

type Context = WebsocketContext<Session>

Actor execution context type

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

Called after an actor is stopped.

impl<T: Serialize> Handler<Arc<Emiter<T>>> for Session

type Result = Result<(), &'static str>

The type of value that this handler will return.

fn handle( &mut self, msg: Arc<Emiter<T>>, ctx: &mut Self::Context, ) -> Self::Result

This method is called for every message received by this actor.

impl<T: Serialize> Handler<AuthSuccess<T>> for Session

type Result = Result<(), &'static str>

The type of value that this handler will return.

fn handle( &mut self, msg: AuthSuccess<T>, ctx: &mut Self::Context, ) -> Self::Result

This method is called for every message received by this actor.

impl Handler<ConnectPacket> for Session

建立连接回应给客户端处理

type Result = Result<(), &'static str>

The type of value that this handler will return.

fn handle( &mut self, msg: ConnectPacket, ctx: &mut Self::Context, ) -> Self::Result

This method is called for every message received by this actor.

impl Handler<OpenPacket> for Session

type Result = Result<(), &'static str>

The type of value that this handler will return.

fn handle(&mut self, msg: OpenPacket, ctx: &mut Self::Context) -> Self::Result

This method is called for every message received by this actor.

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

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

收到消息后的处理

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.