sclass SourceTriggeredStream<A> {
  event newElement(A a);
}