Flows

Added in 1.0.0-alpha05

public final class Flows

Summary

Public methods
static final @NonNull Observable<@NonNull T>
<T extends Object> toObservable(
    @NonNull Session session,
    @NonNull Flow<@NonNull T> flow
)

Converts a flow created within the session to an io.reactivex.rxjava3.core.Observable.

Public methods

toObservable

public static final @NonNull Observable<@NonNull T> <T extends Object> toObservable(
    @NonNull Session session,
    @NonNull Flow<@NonNull T> flow
)

Converts a flow created within the session to an io.reactivex.rxjava3.core.Observable.

The returned io.reactivex.rxjava3.core.Observable will be given the session's CoroutineContext.

Parameters
@NonNull Session session

the androidx.xr.runtime.Session that originated the flow.
@NonNull Flow<@NonNull T> flow

the kotlinx.coroutines.flow.Flow to convert to an io.reactivex.rxjava3.core.Observable.