pub fn observe_with_handle<F>(&self, subscriber: F, handle_id: u128)
    where
        F: 'a + FnMut(&Sig),
  {
    match self.subscribers {
      DependentStreams::Own(ref subscribers) => {
        subscribers.borrow_mut().push(Box::new(
          (handle_id, subscriber)
        ))
      },
      DependentStreams::Weak(ref weak) => {
        if let Some(subscribers) = weak.upgrade() {
          subscribers.borrow_mut().push(Box::new(
            (handle_id, subscriber)
          ));
        }
      }
    }
  }
/// Observe a stream signal output flowing out of the stream.
///
/// Do not abuse this function, as its primary use is to build other combinators.
Observe a stream signal output flowing out of the stream.
Do not abuse this function, as its primary use is to build other combinators.
Observe a stream signal output flowing out of the stream . Do not abuse this function as its primary use is to build other combinators .
pub fn observe_with_handle<F>(&self, subscriber: F, handle_id: u128)
    where
        F: 'a + FnMut(&Sig),
  {
    match self.subscribers {
      DependentStreams::Own(ref subscribers) => {
        subscribers.borrow_mut().push(Box::new(
          (handle_id, subscriber)
        ))
      },
      DependentStreams::Weak(ref weak) => {
        if let Some(subscribers) = weak.upgrade() {
          subscribers.borrow_mut().push(Box::new(
            (handle_id, subscriber)
          ));
        }
      }
    }
  }
pub fn observe_with_handle < F > ( & self , subscriber : F , handle_id : u128 ) where F : ' a + FnMut ( & Sig ) , { match self . subscribers { DependentStreams :: Own ( ref subscribers ) => { subscribers . borrow_mut ( ) . push ( Box :: new ( ( handle_id , subscriber ) ) ) } , DependentStreams :: Weak ( ref weak ) => { if let Some ( subscribers ) = weak . upgrade ( ) { subscribers . borrow_mut ( ) . push ( Box :: new ( ( handle_id , subscriber ) ) ) ; } } } }
Observe a stream signal output flowing out of the stream.
Observe a stream signal output flowing out of the stream .
&self
subscriber
F
handle_id
u128
&self
subscriber
F
handle_id
u128