krpc_core/protocol/
mod.rs

1use std::{collections::HashMap, sync::Arc};
2
3use krpc_common::RpcServer;
4use tokio::{
5    net::TcpStream,
6    sync::{broadcast, mpsc},
7};
8
9use crate::filter::RpcServerRoute;
10
11pub mod server;
12mod h2_handler;
13
14
15pub struct StreamHandler {
16    pub tcp_stream: TcpStream,
17    pub filter_list: Vec<RpcServerRoute>,
18    pub rpc_server: HashMap<String, Arc<Box<dyn RpcServer>>>,
19    pub shutdown: broadcast::Receiver<()>,
20    pub _shutdown_complete: mpsc::Sender<()>,
21}