<br />
<b>Warning</b>:  session_start(): open(/var/lib/php/sessions/sess_8qhvoa4klvp9ibd1d93jatvrol, O_RDWR) failed: No space left on device (28) in <b>/var/www/tb-usercake/models/config.php</b> on line <b>51</b><br />
<br />
<b>Warning</b>:  session_start(): Failed to read session data: files (path: /var/lib/php/sessions) in <b>/var/www/tb-usercake/models/config.php</b> on line <b>51</b><br />
sclass SourceTriggeredStream<A> extends Meta {
  DoneFlag ended = new(true);
  volatile A lastElement;
  new AtomicLong elementCount; 

  event newElement(A a) {
    lastElement = a;
    inc(elementCount);
  }
  
  void onNewElement(Runnable r) { onNewElement(runnableToIVF0(r)); }

  A get() { ret lastElement; }
  long elementCount() { ret elementCount!; }
  
  void end { ended.raise(); }
  bool ended() { ret ended.isUp(); }
  
  void catchError(Runnable r) {
    main catchError(ended, r);
  }
  
  // on new element, call consumer in same thread
  void directlyFeedInto(Consumer<A> consumer) {
    if (consumer != null)
      onNewElement(a -> consumer.accept(a));
  }
}