Share

data class Share(val buffer: Int = DefaultBufferSize, val replay: Int = 0, val overflow: BufferOverflow = BufferOverflow.SUSPEND) : ActionShareBehavior

Actions will be distributed to all subscribers equally. Each subscriber will receive a reference to a single instance of the action that was sent from any store. Use when you want to have multiple subscribers that each consume actions. Be aware that, however, if there's at least one subscriber, they will consume an action entirely (i.e. other subscribers won't receive it when they "return" if they weren't present at the time of emission).

Parameters

buffer

How many actions will be buffered when consumer processes them slower than they are emitted

replay

How many actions will be replayed to each new subscriber

overflow

How actions that overflow the buffer are handled.

See also

BufferOverflow

Constructors

Link copied to clipboard
constructor(buffer: Int = DefaultBufferSize, replay: Int = 0, overflow: BufferOverflow = BufferOverflow.SUSPEND)

Properties

Link copied to clipboard
val buffer: Int
Link copied to clipboard
val overflow: BufferOverflow
Link copied to clipboard
val replay: Int = 0