pub async fn into_stream_forwarder<IN, S>(mut self, mut stream: S) -> Result<(), SendError>
    where
        A: Actor + Send + Notifiable<IN> + 'static,
        S: Send + Stream<Item = IN> + Unpin,
        IN: Send + 'static,
    {
        while let Some(message) = stream.next().await {
            self.notify(message).await?;
        }
        Ok(())
    }
/// Combines provided stream and this `Address` object, returning a future
/// that will run while stream yields messages and send them to the server.
///
/// [`Actor`] associated with this `Address` must implmenet [`Notifiable`] trait
/// to process messages from the stream.
///
/// Future returned by this method should not normally be directly `await`ed,
/// but rather is expected to be used in some kind of `spawn` function of
/// the used runtime (e.g. `tokio::spawn` or `async_std::task::spawn`).
///
/// ## Errors
///
/// Will return an error in case associated actor stopped working.
Combines provided stream and this `Address` object, returning a future
that will run while stream yields messages and send them to the server.



Future returned by this method should not normally be directly `await`ed,
but rather is expected to be used in some kind of `spawn` function of
the used runtime .
Combines provided stream and this ` Address ` object returning a future that will run while stream yields messages and send them to the server . Future returned by this method should not normally be directly ` await ` ed but rather is expected to be used in some kind of ` spawn ` function of the used runtime .
pub async fn into_stream_forwarder<IN, S>(mut self, mut stream: S) -> Result<(), SendError>
    where
        A: Actor + Send + Notifiable<IN> + 'static,
        S: Send + Stream<Item = IN> + Unpin,
        IN: Send + 'static,
    {
        while let Some(message) = stream.next().await {
            self.notify(message).await?;
        }
        Ok(())
    }
pub async fn into_stream_forwarder < IN , S > ( mut self , mut stream : S ) -> Result < ( ) , SendError > where A : Actor + Send + Notifiable < IN > + ' static , S : Send + Stream < Item = IN > + Unpin , IN : Send + ' static , { while let Some ( message ) = stream . next ( ) . await { self . notify ( message ) . await ? ; } Ok ( ( ) ) }
Combines provided stream and this `Address` object, returning a future
that will run while stream yields messages and send them to the server.
Combines provided stream and this ` Address ` object returning a future that will run while stream yields messages and send them to the server .
mut self
stream
S
mut self
stream
S
errors
Will return an error in case associated actor stopped working.
Will return an error in case associated actor stopped working .