Package-level declarations
Types
Link copied to clipboard
A WorkRunner that launches work on a CoroutineDispatcher.
Link copied to clipboard
interface ExecutionPolicy
Defines execution behavior of handler functions added to a subtypeEffectHandler.
Link copied to clipboard
object FlowMobius
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Used to indicate that an FlowMobiusLoop transformer has received an kotlinx.coroutines.flow.catch call, which is illegal. This exception means Mobius is in an undefined state and should be considered a fatal programmer error.
Functions
Link copied to clipboard
Transforms the FlowTransformer into a Connectable.
Link copied to clipboard
Constructs a Connectable that applies transform to map a Flow of I into a Flow of O.
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
fun <F : Any, E> subtypeEffectHandler(block: SubtypeEffectHandlerBuilder<F, E>.() -> Unit): FlowTransformer<F, E>
fun <F : Any, E> subtypeEffectHandler(executionPolicy: ExecutionPolicy, block: SubtypeEffectHandlerBuilder<F, E>.() -> Unit): FlowTransformer<F, E>
Link copied to clipboard
Create an EventSource that emits each E from this Flow.
Link copied to clipboard
Create a Flow that emits each E from this EventSource.