RxLua/tests
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