async fn handle_request_task(
server: Arc<Server>,
channel: Arc<Channel>,
sub_senders: Arc<RwLock<HashMap<SubscriptionID, Sender<NewNotification>>>>,
req: Request<()>,
stream: RequestStream<BidiStream<Bytes>, Bytes>,
) -> Result<()>