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