Function stream_reader_task 

async fn stream_reader_task<R>(
    server: Arc<Server>,
    reader: R,
    queue: Arc<AsyncQueue<Value>>,
    channel: Arc<Channel>,
) -> Result<()>
where
    R: MessageRx<Message = Value> + Send,