1 import { Subscriber } from '../Subscriber';
2 export function isEmpty() {
3 return (source) => source.lift(new IsEmptyOperator());
5 class IsEmptyOperator {
6 call(observer, source) {
7 return source.subscribe(new IsEmptySubscriber(observer));
10 class IsEmptySubscriber extends Subscriber {
11 constructor(destination) {
14 notifyComplete(isEmpty) {
15 const destination = this.destination;
16 destination.next(isEmpty);
17 destination.complete();
20 this.notifyComplete(false);
23 this.notifyComplete(true);
26 //# sourceMappingURL=isEmpty.js.map