1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
| import { Subscriber } from '../Subscriber';
| export function createOperatorSubscriber(destination, onNext, onComplete, onError, onFinalize) {
| return new OperatorSubscriber(destination, onNext, onComplete, onError, onFinalize);
| }
| export class OperatorSubscriber extends Subscriber {
| constructor(destination, onNext, onComplete, onError, onFinalize, shouldUnsubscribe) {
| super(destination);
| this.onFinalize = onFinalize;
| this.shouldUnsubscribe = shouldUnsubscribe;
| this._next = onNext
| ? function (value) {
| try {
| onNext(value);
| }
| catch (err) {
| destination.error(err);
| }
| }
| : super._next;
| this._error = onError
| ? function (err) {
| try {
| onError(err);
| }
| catch (err) {
| destination.error(err);
| }
| finally {
| this.unsubscribe();
| }
| }
| : super._error;
| this._complete = onComplete
| ? function () {
| try {
| onComplete();
| }
| catch (err) {
| destination.error(err);
| }
| finally {
| this.unsubscribe();
| }
| }
| : super._complete;
| }
| unsubscribe() {
| var _a;
| if (!this.shouldUnsubscribe || this.shouldUnsubscribe()) {
| const { closed } = this;
| super.unsubscribe();
| !closed && ((_a = this.onFinalize) === null || _a === void 0 ? void 0 : _a.call(this));
| }
| }
| }
| //# sourceMappingURL=OperatorSubscriber.js.map
|
|
