Function stream_writer_task 

async fn stream_writer_task<W>(
    writer: W,
    queue: Arc<AsyncQueue<Value>>,
    ch_rx: Receiver<NewNotification>,
    notification_encoder: fn(NewNotification) -> Notification,
) -> Result<()>
where
    W: MessageTx<Message = Value> + Send,