mirror of
https://github.com/actix/actix-website
synced 2025-02-08 22:36:07 +01:00
30 lines
740 B
Rust
30 lines
740 B
Rust
|
// <websockets>
|
||
|
|
// use actix::*;
|
||
|
|
// use actix_web::*;
|
||
|
|
|
||
|
|
// /// Define http actor
|
||
|
|
// struct Ws;
|
||
|
|
|
||
|
|
// impl Actor for Ws {
|
||
|
|
// type Context = ws::WebsocketContext<Self>;
|
||
|
|
// }
|
||
|
|
|
||
|
|
// /// Handler for ws::Message message
|
||
|
|
// impl StreamHandler<ws::Message, ws::ProtocolError> for Ws {
|
||
|
|
// fn handle(&mut self, msg: ws::Message, ctx: &mut Self::Context) {
|
||
|
|
// match msg {
|
||
|
|
// ws::Message::Ping(msg) => ctx.pong(&msg),
|
||
|
|
// ws::Message::Text(text) => ctx.text(text),
|
||
|
|
// ws::Message::Binary(bin) => ctx.binary(bin),
|
||
|
|
// _ => (),
|
||
|
|
// }
|
||
|
|
// }
|
||
|
|
// }
|
||
|
|
|
||
|
|
// fn main() {
|
||
|
|
// App::new()
|
||
|
|
// .resource("/ws/", |r| r.f(|req| ws::start(req, Ws)))
|
||
|
|
// .finish();
|
||
|
|
// }
|
||
|
|
// </websockets>
|