pub fn emit(self, mut runtime: &mut Runtime, value: E) {
    if self.runtime.is_currently_emitted.get() {
      return;
    }

    self.runtime.is_currently_emitted.set(true);
    self.add_update_on_end_of_instant(runtime);

    self.gather_value(value);

    // Empty the list of continuations to execute during next instant if there is *no* signal
    self.runtime.call_later_on_absent.borrow_mut().clear();
    self.runtime.call_later_on_absent_registered.set(false);

    // Add awaiting continuations to current instant
    self.add_on_present_continuations_to_runtime(runtime);
    self.add_later_on_present_continuations_to_runtime(runtime);
  }
/// Emit the signal during current instant.
///
/// It updates the state of the signal runtime, gather the given value,
/// drop any pending continuations to run if the signal was absent,
/// and add all pending continuations to run if the signal is present to the runtime.
Emit the signal during current instant.
It updates the state of the signal runtime, gather the given value,
drop any pending continuations to run if the signal was absent,
and add all pending continuations to run if the signal is present to the runtime.
Emit the signal during current instant . It updates the state of the signal runtime gather the given value drop any pending continuations to run if the signal was absent and add all pending continuations to run if the signal is present to the runtime .
pub fn emit(self, mut runtime: &mut Runtime, value: E) {
    if self.runtime.is_currently_emitted.get() {
      return;
    }
    self.runtime.is_currently_emitted.set(true);
    self.add_update_on_end_of_instant(runtime);
    self.gather_value(value);
    // Empty the list of continuations to execute during next instant if there is *no* signal
    self.runtime.call_later_on_absent.borrow_mut().clear();
    self.runtime.call_later_on_absent_registered.set(false);
    // Add awaiting continuations to current instant
    self.add_on_present_continuations_to_runtime(runtime);
    self.add_later_on_present_continuations_to_runtime(runtime);
  }
pub fn emit ( self , mut runtime : & mut Runtime , value : E ) { if self . runtime . is_currently_emitted . get ( ) { return ; } self . runtime . is_currently_emitted . set ( true ) ; self . add_update_on_end_of_instant ( runtime ) ; self . gather_value ( value ) ; // Empty the list of continuations to execute during next instant if there is *no* signal self . runtime . call_later_on_absent . borrow_mut ( ) . clear ( ) ; self . runtime . call_later_on_absent_registered . set ( false ) ; // Add awaiting continuations to current instant self . add_on_present_continuations_to_runtime ( runtime ) ; self . add_later_on_present_continuations_to_runtime ( runtime ) ; }
Emit the signal during current instant.
Emit the signal during current instant .
self
runtime
&mut Runtime
value
E