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
/
sample.ts
diff --git
a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/sample.ts
b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/sample.ts
index 5665dec1ba768cb3354ddd65f0ec54875a1f1aae..1a26baff32034df06cfb514a00c8a73ad53fc5af 100644
(file)
--- a/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/sample.ts
+++ b/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/sample.ts
@@
-1,11
+1,9
@@
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 { OuterSubscriber } from '../OuterSubscriber';
-import { InnerSubscriber } from '../InnerSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
import { MonoTypeOperatorFunction, TeardownLogic } from '../types';
import { MonoTypeOperatorFunction, TeardownLogic } from '../types';
+import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe';
/**
* Emits the most recently emitted value from the source Observable whenever
/**
* Emits the most recently emitted value from the source Observable whenever
@@
-58,7
+56,7
@@
class SampleOperator<T> implements Operator<T, T> {
call(subscriber: Subscriber<T>, source: any): TeardownLogic {
const sampleSubscriber = new SampleSubscriber(subscriber);
const subscription = source.subscribe(sampleSubscriber);
call(subscriber: Subscriber<T>, source: any): TeardownLogic {
const sampleSubscriber = new SampleSubscriber(subscriber);
const subscription = source.subscribe(sampleSubscriber);
- subscription.add(
subscribeToResult(sampleSubscriber, this.notifier
));
+ subscription.add(
innerSubscribe(this.notifier, new SimpleInnerSubscriber(sampleSubscriber)
));
return subscription;
}
}
return subscription;
}
}
@@
-68,8
+66,8
@@
class SampleOperator<T> implements Operator<T, T> {
* @ignore
* @extends {Ignored}
*/
* @ignore
* @extends {Ignored}
*/
-class SampleSubscriber<T, R> extends OuterSubscriber<T, R> {
- private value: T;
+class SampleSubscriber<T, R> extends
Simple
OuterSubscriber<T, R> {
+ private value
?
: T;
private hasValue: boolean = false;
protected _next(value: T) {
private hasValue: boolean = false;
protected _next(value: T) {
@@
-77,9
+75,7
@@
class SampleSubscriber<T, R> extends OuterSubscriber<T, R> {
this.hasValue = true;
}
this.hasValue = true;
}
- notifyNext(outerValue: T, innerValue: R,
- outerIndex: number, innerIndex: number,
- innerSub: InnerSubscriber<T, R>): void {
+ notifyNext(): void {
this.emitValue();
}
this.emitValue();
}
@@
-90,7
+86,7
@@
class SampleSubscriber<T, R> extends OuterSubscriber<T, R> {
emitValue() {
if (this.hasValue) {
this.hasValue = false;
emitValue() {
if (this.hasValue) {
this.hasValue = false;
- this.destination.next
(this.value
);
+ this.destination.next
!(this.value!
);
}
}
}
}
}
}