- c7e9b56 Allocate underlying buffer in ArrayChannel in on-demand manner (#1388) by Vsevolod Tolstopyatov · 5 years ago
- 4e47af4 Optimize debounce operator allocation pressure by using conflated produce. Previously it was not possible due to not implemented #1235 by Vsevolod Tolstopyatov · 5 years ago
- 897f02e Get rid of NonRecoverableThrowable, mention way to opt-out stacktrace… (#1420) by Vsevolod Tolstopyatov · 5 years ago
- 0905c62 Properly enforce flow invariant when flow is used from "suspend fun m… (#1426) by Vsevolod Tolstopyatov · 5 years ago
- f4e9553 Deprecate delayFlow and delayEach by Roman Elizarov · 5 years ago
- 420fed9 Properly use acquired permits in Semaphore by Turing Technologies (Wynne Plaga) · 5 years ago
- a3763e8 Improve Semaphore API by Vsevolod Tolstopyatov · 5 years ago
- a33bf5a Check for cancellation in concurrent flow merge on each element by Vsevolod Tolstopyatov · 5 years ago
- 55bead0 Deprecate flowWith with ERROR by Vsevolod Tolstopyatov · 5 years ago
- 41428a3 Flow.kt: fix typos and rephrase some expressions for better readability (#1408) by Yanis Batura · 5 years ago
- ed97260 Get rid of top-level functions in Migration.kt to improve experience of users who depend on any reactive library and kotlinx.coroutines by Vsevolod Tolstopyatov · 5 years ago
- b37ca3a Properly handle scoped coroutines in JobSupport.cancelParent by Vsevolod Tolstopyatov · 5 years ago
- 684a97b Use regular produce instead of flowProduce in channelFlow by Vsevolod Tolstopyatov · 5 years ago
- 131c320 Use US English Spelling for BehaviorSubject. by Nelson Osacky · 5 years ago
- 60101b8 Fixed typo in Migration.concatWith replaceWith code by Roman Elizarov · 5 years ago
- 023ea30 Merge branch 'master' into develop by Vsevolod Tolstopyatov · 5 years ago
- dc4a474 Stabilize core flow (#1352) by Vsevolod Tolstopyatov · 5 years ago
- 4809393 Protect event loop data structures from nonmonothonic nanoTime by Roman Elizarov · 5 years ago
- 98a9705 Move event loop infrastructure to common code by Roman Elizarov · 5 years ago
- fe41869 Cancel extensions for CoroutineScope and Job by Vsevolod Tolstopyatov · 5 years ago
- 91cc13a withIndex and collectIndexed operators by Vsevolod Tolstopyatov · 5 years ago
- f6387a7 Fuse consumeAsFlow with channel-using flow operators by Roman Elizarov · 5 years ago
- f8b43e1 Introduce ReceiveChannel.consumeAsFlow and FlowCollector.emitAll(chan) by Roman Elizarov · 5 years ago
- a8904e2 Channel.receiveOrNull becomes extension, internal receiveOrClosed added by Vsevolod Tolstopyatov · 5 years ago
- 63b6e27 Add Flow.onStart, support emit in onCompletion (#1348) by Roman Elizarov · 5 years ago
- f22604b Recover stacktraces for no-dispatched continuations, so recovery works in 'suspend fun main' cases to further improve user experience by Vsevolod Tolstopyatov · 5 years ago
- d100a3f Reactive scopeless (#1341) by Vsevolod Tolstopyatov · 5 years ago
- ace5899 Add distinctUntilChanged operator that uses a comparator function instead of a key extractor. by Zach Klippenstein · 5 years ago
- 9077b01 Cancellation in `Semaphore` should resume the next waiting acquirer if and only if the canceled request has been resumed under a race by Nikita Koval · 5 years ago
- 681195a Use the correct builder method `flowChannel` in the checkContext error description by Paul Woitaschek · 5 years ago
- f75cc17 Fixed sample to use `awaitClose` instead of `await` by Paul Woitaschek · 5 years ago
- b5a8493 Replace unneeded type parameter with projection by Louis CAD · 5 years ago
- 583d39d Rewrite assertions so that they are checked only in debug mode by Roman Elizarov · 5 years ago
- cd5ac0b Replace hand-rolled arraycopy with stdlib copyInto by Louis CAD · 5 years ago
- 8d8b6eb Declarative flow operators (#1291) by Vsevolod Tolstopyatov · 5 years ago
- 502610e Decouple asFlow from batchSize and move it to buffer instead, promote… (#1279) by Vsevolod Tolstopyatov · 5 years ago
- 91d9f7c Flow exceptions handling facilities (#1280) by Roman Elizarov · 5 years ago
- 2ace4c6 Fix flowViaChannel closing immediately. (#1260) by Louis CAD · 5 years ago
- 03b9bd1 Merge branch 'master' into develop by Vsevolod Tolstopyatov · 5 years ago
- 18e3a4a Mark Flow.collect as internal to prevent its direct implementation and provide AbstractFlow instead that enforces context preservation guarantees by Vsevolod Tolstopyatov · 5 years ago
- 3216825 Use real semaphore in flatten/flatMapMerge by Roman Elizarov · 5 years ago
- 253e8eb Add fast `Semaphore`. by Nikita Koval · 5 years ago
- aa3d1ae Deprecate Channel operators by Vsevolod Tolstopyatov · 5 years ago
- 15c7d0f Mark Flow declarations as experimental by Vsevolod Tolstopyatov · 5 years ago
- d5478b6 More operators (#1236) by Vsevolod Tolstopyatov · 5 years ago
- e2a5671 Flow scope (#1227) by Vsevolod Tolstopyatov · 5 years ago
- db52e97 Flow.conflate operator by Roman Elizarov · 5 years ago
- 3971df3 Rename flow ChannelFlow.kt file to Channels.kt by Roman Elizarov · 5 years ago
- b77a80c Flow: decouple buffer size from various operators and fuse by Roman Elizarov · 5 years ago
- b73ebdc Adjust behavior of conflated channel to deliver last value by Roman Elizarov · 5 years ago
- f44942a Deprecate flowWith operator by Vsevolod Tolstopyatov · 5 years ago
- c81dc91 Documentation improvements (#1229) by Vsevolod Tolstopyatov · 5 years ago
- 9b05908 Consolidate NullSurrogate with Symbol and rename it to NULL by Roman Elizarov · 5 years ago
- 15ee8a3 SafeCollector rework (#1196) by Vsevolod Tolstopyatov · 5 years ago
- b08d61c New flow builder: channelFlow (and its alias callbackFlow) and supple… (#1214) by Vsevolod Tolstopyatov · 5 years ago
- f939617 Merge pull request #1161 from Kotlin/flow-performance-improvements by Vsevolod Tolstopyatov · 5 years ago
- 997d2f2 Ignore cancellation cause thrown from the upstream suspension point in retry and onError by Vsevolod Tolstopyatov · 5 years ago
- 8fbd8b7 Recursively check whether parent handles exception to avoid duplicates reporting when Job() is present in the hierarchy by Vsevolod Tolstopyatov · 5 years ago
- b0f6e05 Improve coroutine exception handling logic by Vsevolod Tolstopyatov · 5 years ago
- 1b590e8 Promote ReceiveChannel.consumeEach and ReceiveChannel.consume to experimental API by Vsevolod Tolstopyatov · 5 years ago
- 5627834 Add combineLatest with multiple flow parameters by Vsevolod Tolstopyatov · 5 years ago
- d811d3a Do not fill in stacktrace in AbortFlowException, update benchmark results by Vsevolod Tolstopyatov · 5 years ago
- e35637a Fix overflow bug in Flow.drop by Eduard Wolf · 5 years ago
- 218dc97 Make ChannelIterator.next non-suspending by Vsevolod Tolstopyatov · 5 years ago
- a9f8c0d Make Flow.fold inlineable by Vsevolod Tolstopyatov · 5 years ago
- 2596414 Add flowOf(value), use unsafeFlow in trivial flow builders by Vsevolod Tolstopyatov · 5 years ago
- 641d671 Flow performance improvements: mark crucial Flow DSL (unsafeFlow, collect, transform, map, mapNotNull, filter, filterNot, filterNotNull) as inline by Vsevolod Tolstopyatov · 5 years ago
- c022ab6 Make withContext cancellable on return (instead of atomically cancellable). by Vsevolod Tolstopyatov · 5 years ago
- 725addf Flow documentation improvements by Vsevolod Tolstopyatov · 5 years ago
- 3428774 Fix wording in documentation by Vitus · 5 years ago
- b552d2c Merge remote-tracking branch 'origin/master' into develop by Roman Elizarov · 5 years ago
- 563b7e5 Fix more typos; reword some phrases; add "job:" to textual output in … (#1154) by Yanis Batura · 5 years ago
- 6e3faa7 Fixed spurious exception during select.onJoin clause registration by Roman Elizarov · 5 years ago
- e569bd3 Fix exception types for channels to ensure transparency & reporting (#1158) by Roman Elizarov · 5 years ago
- f8eac76 Rename transform parameters for consistency with stdlib by Roman Elizarov · 5 years ago
- 8140cfe Fix typos and improve article usage in docs by Yanis Batura · 5 years ago
- fe820ba Flow operators: (#1132) by Vsevolod Tolstopyatov · 5 years ago
- 9e9c9a3 Recover stacktrace of CancellationException from suspendCancellable by Roman Elizarov · 5 years ago
- 2740aa5 Fix a race in Job.join that sporadically results in normal completion by Roman Elizarov · 5 years ago
- bb7b3c2 Provide CoroutineScope into flowViaChannel block, but make it non-suspending. by Vsevolod Tolstopyatov · 5 years ago
- f1710a7 More advanced check for self-suppression during the final exception building in Job with enabled stacktrace recovery by Vsevolod Tolstopyatov · 5 years ago
- c20bc93 Prohibit Flow.take(0) by Vsevolod Tolstopyatov · 5 years ago
- e1ac2e5 Fix atomicfu post-processing and dependencies by Roman Elizarov · 5 years ago
- 310f8b7 Merge remote-tracking branch 'origin/master' into develop by Roman Elizarov · 5 years ago
- 564a5a6 Change more "create new" to "create a" by Inego · 5 years ago
- 6da0ccd Change "create new" to "create a" by Inego · 5 years ago
- 596187e Fix more typos by Inego · 5 years ago
- 39f92ca Fix typos (mostly article usage) by Inego · 5 years ago
- ebe519a Fix "note that" comma everywhere by Inego · 5 years ago
- b550afa Specify exception types, add tests on it by Vsevolod Tolstopyatov · 5 years ago
- 8c2606d Version 1.2.0 by Vsevolod Tolstopyatov · 5 years ago
- 61c64cc Flow improvements: by Vsevolod Tolstopyatov · 5 years ago
- c9f25fc Introducing zip and combineLatest Flow operators by Vsevolod Tolstopyatov · 5 years ago
- d3cc25f Rework purity concept: by Vsevolod Tolstopyatov · 5 years ago
- 8788488 FlatMap-related API rework by Vsevolod Tolstopyatov · 5 years ago
- 2a815e8 Do not invoke retry predicate when exceptions is thrown from downstream by Vsevolod Tolstopyatov · 5 years ago
- 35f9ad5 FlatMap improvements: by Vsevolod Tolstopyatov · 5 years ago
- 2b8218a Introduce CancellableContinuation.resume with onCancelling lambda by Roman Elizarov · 5 years ago
- 709f6d7 Improve flowViaChannel docs by Roman Elizarov · 5 years ago
- 8695f97 Undeprecate ReceiveChannel.isEmpty by Vsevolod Tolstopyatov · 5 years ago