1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
mod borsh;
mod serde_json;
use crate::imports::*;
use crate::server::Interface;
use workflow_websocket::server::{Message, Result as WebSocketResult, WebSocketSink};
pub use self::borsh::*;
pub use self::serde_json::*;
#[async_trait]
pub trait ProtocolHandler<ServerContext, ConnectionContext, Ops>:
DowncastSync + Sized + Send + Sync
where
Ops: OpsT,
ServerContext: Clone + Send + Sync + 'static,
ConnectionContext: Clone + Send + Sync + 'static,
{
fn new(methods: Arc<Interface<ServerContext, ConnectionContext, Ops>>) -> Self
where
Self: Sized;
fn encoding(&self) -> Encoding;
async fn handle_message(
&self,
connection_ctx: ConnectionContext,
message: Message,
sink: &WebSocketSink,
) -> WebSocketResult<()>;
}