stream-result-call/io.getstream.result.call/DistinctCall

DistinctCall

class DistinctCall<T : Any>(scope: CoroutineScope, callBuilder: () -> Call<T>, onFinished: () -> Unit) : Call<T>

Reusable wrapper around Call which delivers a single result to all subscribers.

Constructors

DistinctCall

constructor(scope: CoroutineScope, callBuilder: () -> Call<T>, onFinished: () -> Unit)

Functions

await

open suspend override fun await(): Result<T>

Awaits the result of this Call in a suspending way, asynchronously. Safe to call from any CoroutineContext.

cancel

open override fun cancel()

Cancels the execution of the call.

enqueue

open override fun enqueue(callback: Call.Callback<T>)

Executes the call asynchronously, on a background thread. Safe to call from the main thread.

execute

open override fun execute(): Result<T>

Executes the call synchronously, in a blocking way. Only call this from a background thread.

originCall

fun originCall(): Call<T>

Inherited functions

doOnResult

fun <T : Any> Call<T>.doOnResult(scope: CoroutineScope, function: suspend (Result<T>) -> Unit): Call<T>

Run the given function before running the Call.

doOnStart

fun <T : Any> Call<T>.doOnStart(scope: CoroutineScope, function: suspend () -> Unit): Call<T>

Run the given function before running the Call.

enqueue

open fun enqueue()

Executes the call asynchronously, on a background thread. Safe to call from the main thread.

enqueue

fun <T : Any> Call<T>.enqueue(onSuccess: (T) -> Unit = onSuccessStub, onError: (StreamError) -> Unit = onErrorStub)

forceNewRequest

fun <T : Any> Call<T>.forceNewRequest(): Call<T>

Forces a regular call to be used instead of DistinctCall.

launch

fun <T : Any> Call<T>.launch(scope: CoroutineScope)

Launches a call using coroutines scope.

map

fun <T : Any, K : Any> Call<T>.map(mapper: (T) -> K): Call<K>

Maps a Call type to a transformed Call.

onErrorReturn

fun <T : Any> Call<T>.onErrorReturn(scope: CoroutineScope, function: suspend (originalError: StreamError) -> Result<T>): ReturnOnErrorCall<T>

Wraps this Call into ReturnOnErrorCall to return an item specified by side effect function when it encounters an error.

retry

fun <T : Any> Call<T>.retry(scope: CoroutineScope, retryPolicy: RetryPolicy): Call<T>

Wraps the original call with RetryCall wrapper. Allows to retry the original call based on RetryPolicy

fun <T : Any> Call<T>.share(scope: CoroutineScope, identifier: () -> Int): Call<T>

Shares the existing Call instance for the specified identifier. If no existing call found the new Call instance will be provided.

toUnitCall

fun Call<*>.toUnitCall(): Call<Unit>

withPrecondition

fun <T : Any> Call<T>.withPrecondition(scope: CoroutineScope, precondition: suspend () -> Result<Unit>): Call<T>

Run the Call if the given precondition is Result.Success.

zipWith

fun <T : Any, K : Any> Call<T>.zipWith(call: Call<K>): Call<Pair<T, K>>

Zips a Call of T and a given call of K.