pub async fn ws_create_server_stream( state: &Rc<RefCell<OpState>>, transport: Pin<Box<dyn Upgraded>>) -> Result<ResourceId, AnyError>
