Skip to main content

handle_request_task

Function handle_request_task 

Source
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<()>