async fn read_notifications( recv: RequestStream<RecvStream, Bytes>, sub: &Subscription, ) -> Result<()>