(observer, ...args)
| 244 | } |
| 245 | |
| 246 | subscribe(observer, ...args) { |
| 247 | if (typeof observer === "function") { |
| 248 | observer = { |
| 249 | next: observer, |
| 250 | error: args[0], |
| 251 | complete: args[1] |
| 252 | }; |
| 253 | } |
| 254 | else if (typeof observer !== "object") { |
| 255 | observer = {}; |
| 256 | } |
| 257 | |
| 258 | return new Subscription(observer, this._subscriber); |
| 259 | } |
| 260 | |
| 261 | [Symbol.observable]() { return this } |
| 262 |
no outgoing calls
no test coverage detected