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
/
bufferWhen.ts
diff --git
a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/bufferWhen.ts
b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/bufferWhen.ts
index 2c3e96bc2eb356fabd6b71f680443934655aefbc..3ea0169292520b11a2c814572dafc242ffbb4101 100644
(file)
--- a/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/bufferWhen.ts
+++ b/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/bufferWhen.ts
@@
-2,10
+2,8
@@
import { Operator } from '../Operator';
import { Subscriber } from '../Subscriber';
import { Observable } from '../Observable';
import { Subscription } from '../Subscription';
import { Subscriber } from '../Subscriber';
import { Observable } from '../Observable';
import { Subscription } from '../Subscription';
-import { OuterSubscriber } from '../OuterSubscriber';
-import { InnerSubscriber } from '../InnerSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
import { OperatorFunction } from '../types';
import { OperatorFunction } from '../types';
+import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe';
/**
* Buffers the source Observable values, using a factory function of closing
/**
* Buffers the source Observable values, using a factory function of closing
@@
-70,10
+68,10
@@
class BufferWhenOperator<T> implements Operator<T, T[]> {
* @ignore
* @extends {Ignored}
*/
* @ignore
* @extends {Ignored}
*/
-class BufferWhenSubscriber<T> extends OuterSubscriber<T, any> {
- private buffer: T[];
+class BufferWhenSubscriber<T> extends
Simple
OuterSubscriber<T, any> {
+ private buffer
?
: T[];
private subscribing: boolean = false;
private subscribing: boolean = false;
- private closingSubscription: Subscription;
+ private closingSubscription
?
: Subscription;
constructor(destination: Subscriber<T[]>, private closingSelector: () => Observable<any>) {
super(destination);
constructor(destination: Subscriber<T[]>, private closingSelector: () => Observable<any>) {
super(destination);
@@
-81,26
+79,24
@@
class BufferWhenSubscriber<T> extends OuterSubscriber<T, any> {
}
protected _next(value: T) {
}
protected _next(value: T) {
- this.buffer.push(value);
+ this.buffer
!
.push(value);
}
protected _complete() {
const buffer = this.buffer;
if (buffer) {
}
protected _complete() {
const buffer = this.buffer;
if (buffer) {
- this.destination.next(buffer);
+ this.destination.next
!
(buffer);
}
super._complete();
}
/** @deprecated This is an internal implementation detail, do not use. */
_unsubscribe() {
}
super._complete();
}
/** @deprecated This is an internal implementation detail, do not use. */
_unsubscribe() {
- this.buffer =
null
;
+ this.buffer =
undefined
;
this.subscribing = false;
}
this.subscribing = false;
}
- notifyNext(outerValue: T, innerValue: any,
- outerIndex: number, innerIndex: number,
- innerSub: InnerSubscriber<T, any>): void {
+ notifyNext(): void {
this.openBuffer();
}
this.openBuffer();
}
@@
-122,7
+118,7
@@
class BufferWhenSubscriber<T> extends OuterSubscriber<T, any> {
const buffer = this.buffer;
if (this.buffer) {
const buffer = this.buffer;
if (this.buffer) {
- this.destination.next(buffer);
+ this.destination.next
!
(buffer);
}
this.buffer = [];
}
this.buffer = [];
@@
-138,7
+134,7
@@
class BufferWhenSubscriber<T> extends OuterSubscriber<T, any> {
this.closingSubscription = closingSubscription;
this.add(closingSubscription);
this.subscribing = true;
this.closingSubscription = closingSubscription;
this.add(closingSubscription);
this.subscribing = true;
- closingSubscription.add(
subscribeToResult(this, closingNotifier
));
+ closingSubscription.add(
innerSubscribe(closingNotifier, new SimpleInnerSubscriber(this)
));
this.subscribing = false;
}
}
this.subscribing = false;
}
}