Sha256: 892961f8d0b3962b7556b1b283dc5d554b71b722f07d00cb20b601fccb622b23
Contents?: true
Size: 768 Bytes
Versions: 49
Compression:
Stored size: 768 Bytes
Contents
import { Subscriber } from '../Subscriber';
export function isEmpty() {
return (source) => source.lift(new IsEmptyOperator());
}
class IsEmptyOperator {
call(observer, source) {
return source.subscribe(new IsEmptySubscriber(observer));
}
}
/**
* We need this JSDoc comment for affecting ESDoc.
* @ignore
* @extends {Ignored}
*/
class IsEmptySubscriber extends Subscriber {
constructor(destination) {
super(destination);
}
notifyComplete(isEmpty) {
const destination = this.destination;
destination.next(isEmpty);
destination.complete();
}
_next(value) {
this.notifyComplete(false);
}
_complete() {
this.notifyComplete(true);
}
}
//# sourceMappingURL=isEmpty.js.map
Version data entries
49 entries across 49 versions & 4 rubygems