Paolo Bonzini 1cbd5b2ca6 flatten: avoid early completion ...

The flatten operator currently calls onCompleted as soon as the
parent signals that it has completed.  However, there could be
more data incoming from the returned observables; in fact, the
flattened observable might even be infinite.

Track how many subscriptions are still active, and only call
onCompleted at the time of the last completion.

2020-01-14 17:24:33 +01:00

..

all.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

amb.lua

Observable.amb;

2015-10-27 19:56:12 -07:00

asyncsubject.lua

AsyncSubject;

2015-11-10 20:19:01 -08:00

average.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

behaviorsubject.lua

BehaviorSubject tests;

2015-11-12 19:08:48 -08:00

buffer.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

catch.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

combineLatest.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

compact.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

concat.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

contains.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

count.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

defaultIfEmpty.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

distinct.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

distinctUntilChanged.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

elementAt.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

filter.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

find.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

first.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

flatMap.lua

flatten: avoid early completion

2020-01-14 17:24:33 +01:00

flatMapLatest.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

flatten.lua

flatten: avoid early completion

2020-01-14 17:24:33 +01:00

ignoreElements.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

last.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

lust.lua

Update lust to resolve problems from earlier versions

2019-10-09 00:17:06 +02:00

map.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

max.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

merge.lua

Fix merge operator to handle onCompleted of input observables not a destructive way

2018-11-28 17:20:41 +09:00

min.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

observable.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

observer.lua

Formatting;

2019-10-20 14:43:33 -07:00

pack.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

partition.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

pluck.lua

Rename fromValue to of;

2016-10-15 10:31:23 -07:00

reduce.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

reject.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

replaysubject.lua

ReplaySubject;

2015-11-12 19:27:22 -08:00

retry.lua

Observable.retry;

2015-11-05 19:19:32 -08:00

runner.lua

Formatting;

2019-10-20 14:43:33 -07:00

sample.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

scan.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

skip.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

skipLast.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

skipUntil.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

skipWhile.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

startWith.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

subject.lua

Test Subject;

2015-11-12 18:51:04 -08:00

subscription.lua

Test Subscription;

2015-10-27 19:35:57 -07:00

sum.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

switch.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

take.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

takeLast.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

takeUntil.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

takeWhile.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

tap.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

unpack.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

unwrap.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

window.lua

Add an assertion like 'expect(observable).to.produce.error()' to test 'onError'.

2019-03-28 03:04:58 +09:00

with.lua

Fix with operator subscription to unsubscribe from all sources

2018-11-20 14:35:07 +09:00

zip.lua

Add unsubscription test for zip operator

2019-05-07 10:48:47 -07:00