import {Subject} from "rxjs"; class WorldFullMessageStream { private _stream:Subject = new Subject(); public stream = this._stream.asObservable(); onMessage() { this._stream.next(); } } export const worldFullMessageStream = new WorldFullMessageStream();