- 4a53d23 Atomically start coroutines in intermediate Flow operators in order to ensure proper termination, including finally blocks and onCompletion operators (#1829) by Vsevolod Tolstopyatov · 4 years, 6 months ago
- de491d2 Make SafeCollector platform-specific declaration and enforce exceptio… (#1793) by Vsevolod Tolstopyatov · 4 years, 6 months ago
- 4aa3880 Detect missing awaitClose calls in callbackFlow and close channel wit… (#1771) by Vsevolod Tolstopyatov · 4 years, 6 months ago
- 387d1dd Improve test style by Dmitry Khalanskiy · 4 years, 6 months ago
- 345458b ReceiveChannel.receiveAsFlow extension (#1731) by Roman Elizarov · 4 years, 8 months ago
- 1b378ba Introduce merge operator by Vsevolod Tolstopyatov · 4 years, 8 months ago
- 34dcfb1 Rethrow downstream exception during "onCompletion" emissions by Vsevolod Tolstopyatov · 4 years, 9 months ago
- bd1687f Throw NoSuchElementException instead of UnsupportedOperationException in Flow.reduce by Vsevolod Tolstopyatov · 4 years, 9 months ago
- 1a2707b Cleanup CombineParametersTestBase by Vsevolod Tolstopyatov · 4 years, 10 months ago
- ecbfa6d Properly distinguish AbortFlowExceptions from different non-terminal operators by Vsevolod Tolstopyatov · 4 years, 10 months ago
- 83943ef Get rid of deprecated FlowCollector<*>.withContext by Vsevolod Tolstopyatov · 4 years, 10 months ago
- 8248fe4 Make MapTest - testErrorCancelsUpstream - actually test map operator by Lukasz Wojtach · 4 years, 11 months ago
- bd7c030 Optimize Flow.take (#1538) by Vsevolod Tolstopyatov · 5 years ago
- 1f5ab53 flow: fix recursion in combineTransform<T1, T2, R>() by Jan Skrasek · 5 years ago
- 0342a0a Restore context preservation invariant in flatMapMerge (#1452) by Vsevolod Tolstopyatov · 5 years ago
- 9b7c03c Increase to default buffer size to 64 by Vsevolod Tolstopyatov · 5 years ago
- 5b56221 Introducing collectLatest terminal operator by Vsevolod Tolstopyatov · 5 years ago
- 3a95884 Renaming switchMap to flatMapLatest to better reflect its semantics and to have a consistent and meaningful naming scheme for the rest of the 'latest' operators by Vsevolod Tolstopyatov · 5 years ago
- 44c4c56 combineLatest rework 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
- 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
- 684a97b Use regular produce instead of flowProduce in channelFlow by Vsevolod Tolstopyatov · 5 years ago
- 97863c3 Report fatal errors to both onError (to comply the spec fully) and to coroutine context (to eagerly fail as fatal exceptions are not recoverable anyway), cleanup tests after scopeless reactive 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
- 63b6e27 Add Flow.onStart, support emit in onCompletion (#1348) by Roman Elizarov · 5 years ago
- ace5899 Add distinctUntilChanged operator that uses a comparator function instead of a key extractor. by Zach Klippenstein · 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
- a563608 Added a test that ensures proper context in catch/flowOn combinations by Roman Elizarov · 5 years ago
- 91d9f7c Flow exceptions handling facilities (#1280) by Roman Elizarov · 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
- 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
- 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
- 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
- 997d2f2 Ignore cancellation cause thrown from the upstream suspension point in retry and onError by Vsevolod Tolstopyatov · 5 years ago
- 5627834 Add combineLatest with multiple flow parameters by Vsevolod Tolstopyatov · 5 years ago
- e569bd3 Fix exception types for channels to ensure transparency & reporting (#1158) by Roman Elizarov · 5 years ago
- fe820ba Flow operators: (#1132) by Vsevolod Tolstopyatov · 5 years ago
- bb7b3c2 Provide CoroutineScope into flowViaChannel block, but make it non-suspending. by Vsevolod Tolstopyatov · 5 years ago
- c20bc93 Prohibit Flow.take(0) by Vsevolod Tolstopyatov · 5 years ago
- b550afa Specify exception types, add tests on it 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
- d57bfa2 Flow preview implementation by Vsevolod Tolstopyatov · 5 years ago