Function forward_stream 

pub async fn forward_stream<T: Send + 'static>(
    signals: &ConnectionSignals,
    subject: &'static str,
    stream: Pin<Box<dyn Stream<Item = T> + Send>>,
    tx: &Sender<T>,
) -> ForwardOutcome

Forwards items from stream into tx, watching signals.connected for disconnections.

Returns ForwardOutcome::Resubscribe when re-subscription is needed and ForwardOutcome::ReceiverDropped when the channel receiver has been closed.