Flowbius provides interoperability extensions for using Kotlin Flows with Mobius. They allow conversion from Flows to Mobius types and vice versa, as well as utilities to setup Mobius loops using Flows.
Flowbius is analogous to what mobius-rx provides for RxJava/Mobius interoperability.
Flowbius provides converters from Flow types to Mobius types:
// Flow -> EventSource
val eventSource = flowOf(1, 2, 3).asEventSource()
// EventSource -> Flow
val flow = eventSource.asFlow()
// FlowTransformer -> Connectable
val connectable = { source: Flow<String> -> source.map { it.length } }.asConnectable()
// Apply a Connectable to a Flow as a flatMap which merges emissions
val transformedFlow = flow.flatMapMerge(connectable)You can also create a Mobius loop with Flow-based subtype effect handler:
val loop = FlowMobius.loop<Model, Event, Effect>(
update = UpdateLogic(),
effectHandler = subtypeEffectHandler {
addConsumer(::handleEffects)
addFunction(::effectToEvents)
}
).startFrom(Model())You can retrieve Flowbius from Maven Central.
implementation 'com.trello.flowbius:flowbius:0.1.3'
$ ./gradlew tests
Contributions to Flowbius are welcome! Please see CONTRIBUTING.md for details.
Copyright (c) 2022 Atlassian and others. Apache 2.0 licensed, see LICENSE file.
