You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
43 lines
1.4 KiB
43 lines
1.4 KiB
"use strict"; |
|
var __extends = (this && this.__extends) || function (d, b) { |
|
for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; |
|
function __() { this.constructor = d; } |
|
d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __()); |
|
}; |
|
var Subscriber_1 = require('../Subscriber'); |
|
function isEmpty() { |
|
return function (source) { return source.lift(new IsEmptyOperator()); }; |
|
} |
|
exports.isEmpty = isEmpty; |
|
var IsEmptyOperator = (function () { |
|
function IsEmptyOperator() { |
|
} |
|
IsEmptyOperator.prototype.call = function (observer, source) { |
|
return source.subscribe(new IsEmptySubscriber(observer)); |
|
}; |
|
return IsEmptyOperator; |
|
}()); |
|
/** |
|
* We need this JSDoc comment for affecting ESDoc. |
|
* @ignore |
|
* @extends {Ignored} |
|
*/ |
|
var IsEmptySubscriber = (function (_super) { |
|
__extends(IsEmptySubscriber, _super); |
|
function IsEmptySubscriber(destination) { |
|
_super.call(this, destination); |
|
} |
|
IsEmptySubscriber.prototype.notifyComplete = function (isEmpty) { |
|
var destination = this.destination; |
|
destination.next(isEmpty); |
|
destination.complete(); |
|
}; |
|
IsEmptySubscriber.prototype._next = function (value) { |
|
this.notifyComplete(false); |
|
}; |
|
IsEmptySubscriber.prototype._complete = function () { |
|
this.notifyComplete(true); |
|
}; |
|
return IsEmptySubscriber; |
|
}(Subscriber_1.Subscriber)); |
|
//# sourceMappingURL=isEmpty.js.map
|