pub fn recv(&self) -> Receiver<Sig>
  where
    Sig: Clone,
  {
    let (sx, rx) = channel();

    self.observe(move |sig| {
      let _ = sx.send(sig.clone());
    });

    rx
  }
/// Sink a stream.
///
/// This method allows to _receive_ the signal and extract it out of the stream via a channel.
Sink a stream.
This method allows to _receive_ the signal and extract it out of the stream via a channel.
Sink a stream . This method allows to _receive_ the signal and extract it out of the stream via a channel .
pub fn recv(&self) -> Receiver<Sig>
  where
    Sig: Clone,
  {
    let (sx, rx) = channel();
    self.observe(move |sig| {
      let _ = sx.send(sig.clone());
    });
    rx
  }
pub fn recv ( & self ) -> Receiver < Sig > where Sig : Clone , { let ( sx , rx ) = channel ( ) ; self . observe ( move | sig | { let _ = sx . send ( sig . clone ( ) ) ; } ) ; rx }
Sink a stream.
Sink a stream .
&self
&self