pub async fn create_stream_handler<T>(
websocket_base: WebsocketBase,
stream_or_id: String,
id: Option<String>,
) -> Arc<WebsocketStream<T>>where
T: DeserializeOwned + Send + 'static,pub async fn create_stream_handler<T>(
websocket_base: WebsocketBase,
stream_or_id: String,
id: Option<String>,
) -> Arc<WebsocketStream<T>>where
T: DeserializeOwned + Send + 'static,