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.
48 lines
1.6 KiB
48 lines
1.6 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'); |
|
var noop_1 = require('../util/noop'); |
|
/** |
|
* Ignores all items emitted by the source Observable and only passes calls of `complete` or `error`. |
|
* |
|
* <img src="./img/ignoreElements.png" width="100%"> |
|
* |
|
* @return {Observable} An empty Observable that only calls `complete` |
|
* or `error`, based on which one is called by the source Observable. |
|
* @method ignoreElements |
|
* @owner Observable |
|
*/ |
|
function ignoreElements() { |
|
return function ignoreElementsOperatorFunction(source) { |
|
return source.lift(new IgnoreElementsOperator()); |
|
}; |
|
} |
|
exports.ignoreElements = ignoreElements; |
|
var IgnoreElementsOperator = (function () { |
|
function IgnoreElementsOperator() { |
|
} |
|
IgnoreElementsOperator.prototype.call = function (subscriber, source) { |
|
return source.subscribe(new IgnoreElementsSubscriber(subscriber)); |
|
}; |
|
return IgnoreElementsOperator; |
|
}()); |
|
/** |
|
* We need this JSDoc comment for affecting ESDoc. |
|
* @ignore |
|
* @extends {Ignored} |
|
*/ |
|
var IgnoreElementsSubscriber = (function (_super) { |
|
__extends(IgnoreElementsSubscriber, _super); |
|
function IgnoreElementsSubscriber() { |
|
_super.apply(this, arguments); |
|
} |
|
IgnoreElementsSubscriber.prototype._next = function (unused) { |
|
noop_1.noop(); |
|
}; |
|
return IgnoreElementsSubscriber; |
|
}(Subscriber_1.Subscriber)); |
|
//# sourceMappingURL=ignoreElements.js.map
|