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
/
observable
/
zip.ts
diff --git
a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/observable/zip.ts
b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/observable/zip.ts
index fbe0756573b1d6f49bd2c2d1dd2769e61c0795f4..1f03caa30c84991b2db3a64adf005a83a6d07e24 100644
(file)
--- a/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/observable/zip.ts
+++ b/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/observable/zip.ts
@@
-5,10
+5,8
@@
import { Operator } from '../Operator';
import { ObservableInput, PartialObserver, ObservedValueOf } from '../types';
import { Subscriber } from '../Subscriber';
import { Subscription } from '../Subscription';
import { ObservableInput, PartialObserver, ObservedValueOf } from '../types';
import { Subscriber } from '../Subscriber';
import { Subscription } from '../Subscription';
-import { OuterSubscriber } from '../OuterSubscriber';
-import { InnerSubscriber } from '../InnerSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
import { iterator as Symbol_iterator } from '../../internal/symbol/iterator';
import { iterator as Symbol_iterator } from '../../internal/symbol/iterator';
+import { SimpleOuterSubscriber, SimpleInnerSubscriber, innerSubscribe } from '../innerSubscribe';
/* tslint:disable:max-line-length */
/** @deprecated resultSelector is no longer supported, pipe to map instead */
/* tslint:disable:max-line-length */
/** @deprecated resultSelector is no longer supported, pipe to map instead */
@@
-87,7
+85,7
@@
export function zip<O extends ObservableInput<any>, R>(
export class ZipOperator<T, R> implements Operator<T, R> {
export class ZipOperator<T, R> implements Operator<T, R> {
- resultSelector: (...values: Array<any>) => R;
+ resultSelector
?
: (...values: Array<any>) => R;
constructor(resultSelector?: (...values: Array<any>) => R) {
this.resultSelector = resultSelector;
constructor(resultSelector?: (...values: Array<any>) => R) {
this.resultSelector = resultSelector;
@@
-104,17
+102,14
@@
export class ZipOperator<T, R> implements Operator<T, R> {
* @extends {Ignored}
*/
export class ZipSubscriber<T, R> extends Subscriber<T> {
* @extends {Ignored}
*/
export class ZipSubscriber<T, R> extends Subscriber<T> {
- private values: any;
- private resultSelector: (...values: Array<any>) => R;
private iterators: LookAheadIterator<any>[] = [];
private active = 0;
constructor(destination: Subscriber<R>,
private iterators: LookAheadIterator<any>[] = [];
private active = 0;
constructor(destination: Subscriber<R>,
- resultSelector?: (...values: Array<any>) => R,
+
private
resultSelector?: (...values: Array<any>) => R,
values: any = Object.create(null)) {
super(destination);
values: any = Object.create(null)) {
super(destination);
- this.resultSelector = (typeof resultSelector === 'function') ? resultSelector : null;
- this.values = values;
+ this.resultSelector = (typeof resultSelector === 'function') ? resultSelector : undefined;
}
protected _next(value: any) {
}
protected _next(value: any) {
@@
-135,7
+130,7
@@
export class ZipSubscriber<T, R> extends Subscriber<T> {
this.unsubscribe();
if (len === 0) {
this.unsubscribe();
if (len === 0) {
- this.destination.complete();
+ this.destination.complete
!
();
return;
}
return;
}
@@
-144,7
+139,7
@@
export class ZipSubscriber<T, R> extends Subscriber<T> {
let iterator: ZipBufferIterator<any, any> = <any>iterators[i];
if (iterator.stillUnsubscribed) {
const destination = this.destination as Subscription;
let iterator: ZipBufferIterator<any, any> = <any>iterators[i];
if (iterator.stillUnsubscribed) {
const destination = this.destination as Subscription;
- destination.add(iterator.subscribe(
iterator, i
));
+ destination.add(iterator.subscribe());
} else {
this.active--; // not an observable
}
} else {
this.active--; // not an observable
}
@@
-154,7
+149,7
@@
export class ZipSubscriber<T, R> extends Subscriber<T> {
notifyInactive() {
this.active--;
if (this.active === 0) {
notifyInactive() {
this.active--;
if (this.active === 0) {
- this.destination.complete();
+ this.destination.complete
!
();
}
}
}
}
@@
-184,7
+179,7
@@
export class ZipSubscriber<T, R> extends Subscriber<T> {
}
if (result.done) {
}
if (result.done) {
- destination.complete();
+ destination.complete
!
();
return;
}
return;
}
@@
-194,23
+189,23
@@
export class ZipSubscriber<T, R> extends Subscriber<T> {
if (this.resultSelector) {
this._tryresultSelector(args);
} else {
if (this.resultSelector) {
this._tryresultSelector(args);
} else {
- destination.next(args);
+ destination.next
!
(args);
}
if (shouldComplete) {
}
if (shouldComplete) {
- destination.complete();
+ destination.complete
!
();
}
}
protected _tryresultSelector(args: any[]) {
let result: any;
try {
}
}
protected _tryresultSelector(args: any[]) {
let result: any;
try {
- result = this.resultSelector.apply(this, args);
+ result = this.resultSelector
!
.apply(this, args);
} catch (err) {
} catch (err) {
- this.destination.error(err);
+ this.destination.error
!
(err);
return;
}
return;
}
- this.destination.next(result);
+ this.destination.next
!
(result);
}
}
}
}
@@
-236,9
+231,9
@@
class StaticIterator<T> implements LookAheadIterator<T> {
return result;
}
return result;
}
- hasCompleted() {
+ hasCompleted()
: boolean
{
const nextResult = this.nextResult;
const nextResult = this.nextResult;
- return
nextResult && nextResult.done
;
+ return
Boolean(nextResult && nextResult.done)
;
}
}
}
}
@@
-274,7
+269,7
@@
class StaticArrayIterator<T> implements LookAheadIterator<T> {
* @ignore
* @extends {Ignored}
*/
* @ignore
* @extends {Ignored}
*/
-class ZipBufferIterator<T, R> extends OuterSubscriber<T, R> implements LookAheadIterator<T> {
+class ZipBufferIterator<T, R> extends
Simple
OuterSubscriber<T, R> implements LookAheadIterator<T> {
stillUnsubscribed = true;
buffer: T[] = [];
isComplete = false;
stillUnsubscribed = true;
buffer: T[] = [];
isComplete = false;
@@
-296,7
+291,7
@@
class ZipBufferIterator<T, R> extends OuterSubscriber<T, R> implements LookAhead
if (buffer.length === 0 && this.isComplete) {
return { value: null, done: true };
} else {
if (buffer.length === 0 && this.isComplete) {
return { value: null, done: true };
} else {
- return { value: buffer.shift(), done: false };
+ return { value: buffer.shift()
!
, done: false };
}
}
}
}
@@
-313,18
+308,16
@@
class ZipBufferIterator<T, R> extends OuterSubscriber<T, R> implements LookAhead
this.isComplete = true;
this.parent.notifyInactive();
} else {
this.isComplete = true;
this.parent.notifyInactive();
} else {
- this.destination.complete();
+ this.destination.complete
!
();
}
}
}
}
- notifyNext(outerValue: T, innerValue: any,
- outerIndex: number, innerIndex: number,
- innerSub: InnerSubscriber<T, R>): void {
+ notifyNext(innerValue: any): void {
this.buffer.push(innerValue);
this.parent.checkIterators();
}
this.buffer.push(innerValue);
this.parent.checkIterators();
}
- subscribe(
value: any, index: number
) {
- return
subscribeToResult<any, any>(this, this.observable, this, index
);
+ subscribe() {
+ return
innerSubscribe(this.observable, new SimpleInnerSubscriber(this)
);
}
}
}
}