stream-chat-android-core/io.getstream.chat.android.core.internal.coroutines/Tube

Tube

class Tube<T> : Flow<T> , FlowCollector<T>

A synchronous data stream that emits values and completes normally.

Constructors

Link copied to clipboard
constructor()

Functions

Link copied to clipboard
open suspend override fun collect(collector: FlowCollector<T>)

Adds the given collector into collectors and suspends until cancellation.

Link copied to clipboard
open suspend override fun emit(value: T)

Emits a value to the collectors, suspending until the value is fully consumed.