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