core/com.tealium.prism.core.api.pubsub/Observable/callback

callback

open fun <R> callback(block: BiConsumer<T, Consumer<R>>): Observable<R>

Returns an observable that will emit values in a possibly asynchronous manner determined by the given block.

Parameters

block

a block of code, to be executed with the next value from the source, along with the consumer with which to emit values downstream.