this.data$ = new Observable((observer: Observer) => { observer.next(); observer.complete(); });
new Observable((observer: Observer<object>) => { observer.next(data); });