source: trip-planner-front/node_modules/rxjs/_esm2015/internal/Subscriber.js@ eed0bf8

Last change on this file since eed0bf8 was 6a3a178, checked in by Ema <ema_spirova@…>, 3 years ago

initial commit
  • Property mode set to 100644
File size: 7.2 KB
Line 
1import { isFunction } from './util/isFunction';
2import { empty as emptyObserver } from './Observer';
3import { Subscription } from './Subscription';
4import { rxSubscriber as rxSubscriberSymbol } from '../internal/symbol/rxSubscriber';
5import { config } from './config';
6import { hostReportError } from './util/hostReportError';
7export class Subscriber extends Subscription {
8 constructor(destinationOrNext, error, complete) {
9 super();
10 this.syncErrorValue = null;
11 this.syncErrorThrown = false;
12 this.syncErrorThrowable = false;
13 this.isStopped = false;
14 switch (arguments.length) {
15 case 0:
16 this.destination = emptyObserver;
17 break;
18 case 1:
19 if (!destinationOrNext) {
20 this.destination = emptyObserver;
21 break;
22 }
23 if (typeof destinationOrNext === 'object') {
24 if (destinationOrNext instanceof Subscriber) {
25 this.syncErrorThrowable = destinationOrNext.syncErrorThrowable;
26 this.destination = destinationOrNext;
27 destinationOrNext.add(this);
28 }
29 else {
30 this.syncErrorThrowable = true;
31 this.destination = new SafeSubscriber(this, destinationOrNext);
32 }
33 break;
34 }
35 default:
36 this.syncErrorThrowable = true;
37 this.destination = new SafeSubscriber(this, destinationOrNext, error, complete);
38 break;
39 }
40 }
41 [rxSubscriberSymbol]() { return this; }
42 static create(next, error, complete) {
43 const subscriber = new Subscriber(next, error, complete);
44 subscriber.syncErrorThrowable = false;
45 return subscriber;
46 }
47 next(value) {
48 if (!this.isStopped) {
49 this._next(value);
50 }
51 }
52 error(err) {
53 if (!this.isStopped) {
54 this.isStopped = true;
55 this._error(err);
56 }
57 }
58 complete() {
59 if (!this.isStopped) {
60 this.isStopped = true;
61 this._complete();
62 }
63 }
64 unsubscribe() {
65 if (this.closed) {
66 return;
67 }
68 this.isStopped = true;
69 super.unsubscribe();
70 }
71 _next(value) {
72 this.destination.next(value);
73 }
74 _error(err) {
75 this.destination.error(err);
76 this.unsubscribe();
77 }
78 _complete() {
79 this.destination.complete();
80 this.unsubscribe();
81 }
82 _unsubscribeAndRecycle() {
83 const { _parentOrParents } = this;
84 this._parentOrParents = null;
85 this.unsubscribe();
86 this.closed = false;
87 this.isStopped = false;
88 this._parentOrParents = _parentOrParents;
89 return this;
90 }
91}
92export class SafeSubscriber extends Subscriber {
93 constructor(_parentSubscriber, observerOrNext, error, complete) {
94 super();
95 this._parentSubscriber = _parentSubscriber;
96 let next;
97 let context = this;
98 if (isFunction(observerOrNext)) {
99 next = observerOrNext;
100 }
101 else if (observerOrNext) {
102 next = observerOrNext.next;
103 error = observerOrNext.error;
104 complete = observerOrNext.complete;
105 if (observerOrNext !== emptyObserver) {
106 context = Object.create(observerOrNext);
107 if (isFunction(context.unsubscribe)) {
108 this.add(context.unsubscribe.bind(context));
109 }
110 context.unsubscribe = this.unsubscribe.bind(this);
111 }
112 }
113 this._context = context;
114 this._next = next;
115 this._error = error;
116 this._complete = complete;
117 }
118 next(value) {
119 if (!this.isStopped && this._next) {
120 const { _parentSubscriber } = this;
121 if (!config.useDeprecatedSynchronousErrorHandling || !_parentSubscriber.syncErrorThrowable) {
122 this.__tryOrUnsub(this._next, value);
123 }
124 else if (this.__tryOrSetError(_parentSubscriber, this._next, value)) {
125 this.unsubscribe();
126 }
127 }
128 }
129 error(err) {
130 if (!this.isStopped) {
131 const { _parentSubscriber } = this;
132 const { useDeprecatedSynchronousErrorHandling } = config;
133 if (this._error) {
134 if (!useDeprecatedSynchronousErrorHandling || !_parentSubscriber.syncErrorThrowable) {
135 this.__tryOrUnsub(this._error, err);
136 this.unsubscribe();
137 }
138 else {
139 this.__tryOrSetError(_parentSubscriber, this._error, err);
140 this.unsubscribe();
141 }
142 }
143 else if (!_parentSubscriber.syncErrorThrowable) {
144 this.unsubscribe();
145 if (useDeprecatedSynchronousErrorHandling) {
146 throw err;
147 }
148 hostReportError(err);
149 }
150 else {
151 if (useDeprecatedSynchronousErrorHandling) {
152 _parentSubscriber.syncErrorValue = err;
153 _parentSubscriber.syncErrorThrown = true;
154 }
155 else {
156 hostReportError(err);
157 }
158 this.unsubscribe();
159 }
160 }
161 }
162 complete() {
163 if (!this.isStopped) {
164 const { _parentSubscriber } = this;
165 if (this._complete) {
166 const wrappedComplete = () => this._complete.call(this._context);
167 if (!config.useDeprecatedSynchronousErrorHandling || !_parentSubscriber.syncErrorThrowable) {
168 this.__tryOrUnsub(wrappedComplete);
169 this.unsubscribe();
170 }
171 else {
172 this.__tryOrSetError(_parentSubscriber, wrappedComplete);
173 this.unsubscribe();
174 }
175 }
176 else {
177 this.unsubscribe();
178 }
179 }
180 }
181 __tryOrUnsub(fn, value) {
182 try {
183 fn.call(this._context, value);
184 }
185 catch (err) {
186 this.unsubscribe();
187 if (config.useDeprecatedSynchronousErrorHandling) {
188 throw err;
189 }
190 else {
191 hostReportError(err);
192 }
193 }
194 }
195 __tryOrSetError(parent, fn, value) {
196 if (!config.useDeprecatedSynchronousErrorHandling) {
197 throw new Error('bad call');
198 }
199 try {
200 fn.call(this._context, value);
201 }
202 catch (err) {
203 if (config.useDeprecatedSynchronousErrorHandling) {
204 parent.syncErrorValue = err;
205 parent.syncErrorThrown = true;
206 return true;
207 }
208 else {
209 hostReportError(err);
210 return true;
211 }
212 }
213 return false;
214 }
215 _unsubscribe() {
216 const { _parentSubscriber } = this;
217 this._context = null;
218 this._parentSubscriber = null;
219 _parentSubscriber.unsubscribe();
220 }
221}
222//# sourceMappingURL=Subscriber.js.map
Note: See TracBrowser for help on using the repository browser.