Kotlin multi-platform implementation of Reactive Extensions
Observable
flatMap
, flatMapCompletable
, flatMapMaybe
and flatMapSingle
operators without maxConcurrency
argument, maxConcurrency
now has the default value Int.MAX_VALUE
(#646 by @emartynov)Completable#asMaybe
and Completable#asObservable
(#648 by @emartynov)action
argument of Maybe#doOnAfterSuccess
operator is renamed to consumer
(#648 by @emartynov)startDelay
and period
arguments in observableInterval
operator, removed the operator without period
argument (#648 by @emartynov)Observable<T>.replay
operator without arguments is removed, its bufferSize
argument now has the default value Int.MAX_VALUE
(#648 by @emartynov)repeat
operator's argument count: Int = -1
is changed with times: Long = Long.MAX_VALUE
(#650 by @emartynov)retry
operator's argument predicate: (attempt: Int, Throwable) -> Boolean
is changed to predicate: (attempt: Long, Throwable) -> Boolean
(#650 by @emartynov)Observable#repeat
with times = 0
now returns empty Observable
(e.g. repeats the sequence at most specified amount of times) (#686 by @arkivanov)flatMap
with resultSelector
(#684 by @arkivanov)Observable#scan
accumulate argument from accumulate
to accumulator
(#688 by @arkivanov)iosArm32
and linuxArm32Hfp
targets (#705 by @arkivanov)threadLocal
operators and flags (#710 by @arkivanov)freeze
function and aligned all related APIs (#717 by @arkivanov)utils
module is renamed to utils-internal
, all APIs in this module are annotated with InternalReaktiveApi
(#730 by @arkivanov)jvmTarget
is now set to JVM_1_8
(#733 by @arkivanov)kotlin.time.Duration
(#738, #740, #741, #742, by @arkivanov)asRxJava2CompletableSource
, asRxJava2MaybeSource
, asRxJava2ObservableSource
and asRxJava2SingleSource
extensions (#743 by @arkivanov)Observable#buffer
's limit
argument of type Int
instead of Long
(#744 by @arkivanov)Scheduler#asCoroutineDispatcher
and CoroutineContext#asScheduler
interop extensions to commonMain
(#748 by @arkivanov)BehaviorObservableWrapper
(#702)ConnectableObservable#refCount
disconnects when new observer is disposed synchronously on emission (#729 by @bjsvedin)using
operators (#674)combineLatest
now emits List
copies instead of same instances (#627)CoroutineExceptionHandler
in coroutines-interop
module for better exception handling (#628)Subjects
(#632, #633, #640, #642, #643)buffer
operators (#645)