Class Stream<T, U>

A concrete implementation of IStream.

import { IStream, Stream } from '@lumino/signaling';

class SomeClass {

  constructor(name: string) {
    this.name = name;
  }

  readonly name: string;

  get pings(): IStream<this, string> {
    return this._pings;
  }

  ping(value: string) {
    this._pings.emit(value);
  }

  private _pings = new Stream<this, string>(this);
}

let m1 = new SomeClass('foo');

m1.pings.connect((_, value: string) => {
  console.log('connect', value);
});

void (async () => {
  for await (const ping of m1.pings) {
    console.log('iterator', ping);
  }
})();

m1.ping('alpha');  // logs: connect alpha
                   // logs: iterator alpha
m1.ping('beta');   // logs: connect beta
                   // logs: iterator beta