projects
/
dotfiles
/
.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Giant blob of minor changes
[dotfiles/.git]
/
.config
/
coc
/
extensions
/
node_modules
/
coc-prettier
/
node_modules
/
rxjs
/
src
/
internal
/
operators
/
exhaust.ts
diff --git
a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/exhaust.ts
b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/exhaust.ts
index ad14b760d65c604286dd6e52808026053b1fdaca..54c5002a307d6591c448cdd7e40ddde20949d915 100644
(file)
--- a/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/exhaust.ts
+++ b/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/exhaust.ts
@@
-1,10
+1,8
@@
import { Operator } from '../Operator';
import { Observable } from '../Observable';
import { Subscriber } from '../Subscriber';
import { Operator } from '../Operator';
import { Observable } from '../Observable';
import { Subscriber } from '../Subscriber';
-import { Subscription } from '../Subscription';
-import { OuterSubscriber } from '../OuterSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
import { ObservableInput, OperatorFunction, TeardownLogic } from '../types';
import { ObservableInput, OperatorFunction, TeardownLogic } from '../types';
+import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe';
export function exhaust<T>(): OperatorFunction<ObservableInput<T>, T>;
export function exhaust<R>(): OperatorFunction<any, R>;
export function exhaust<T>(): OperatorFunction<ObservableInput<T>, T>;
export function exhaust<R>(): OperatorFunction<any, R>;
@@
-68,7
+66,7
@@
class SwitchFirstOperator<T> implements Operator<T, T> {
* @ignore
* @extends {Ignored}
*/
* @ignore
* @extends {Ignored}
*/
-class SwitchFirstSubscriber<T> extends OuterSubscriber<T, T> {
+class SwitchFirstSubscriber<T> extends
Simple
OuterSubscriber<T, T> {
private hasCompleted: boolean = false;
private hasSubscription: boolean = false;
private hasCompleted: boolean = false;
private hasSubscription: boolean = false;
@@
-79,22
+77,21
@@
class SwitchFirstSubscriber<T> extends OuterSubscriber<T, T> {
protected _next(value: T): void {
if (!this.hasSubscription) {
this.hasSubscription = true;
protected _next(value: T): void {
if (!this.hasSubscription) {
this.hasSubscription = true;
- this.add(
subscribeToResult(this, value
));
+ this.add(
innerSubscribe(value, new SimpleInnerSubscriber(this)
));
}
}
protected _complete(): void {
this.hasCompleted = true;
if (!this.hasSubscription) {
}
}
protected _complete(): void {
this.hasCompleted = true;
if (!this.hasSubscription) {
- this.destination.complete();
+ this.destination.complete
!
();
}
}
}
}
- notifyComplete(innerSub: Subscription): void {
- this.remove(innerSub);
+ notifyComplete(): void {
this.hasSubscription = false;
if (this.hasCompleted) {
this.hasSubscription = false;
if (this.hasCompleted) {
- this.destination.complete();
+ this.destination.complete
!
();
}
}
}
}
}
}