pubnub-kotlin-api/com.pubnub.api.endpoints.remoteaction/ComposableRemoteAction

ComposableRemoteAction

class ComposableRemoteAction<T, U>(remoteAction: ExtendedRemoteAction<T>, createNextRemoteAction: (T) -> ExtendedRemoteAction, checkpoint: Boolean) : ExtendedRemoteAction

Constructors

constructor(remoteAction: ExtendedRemoteAction<T>, createNextRemoteAction: (T) -> ExtendedRemoteAction, checkpoint: Boolean)

Types

Companion

object Companion

ComposableBuilder

class ComposableBuilder<T>(remoteAction: ExtendedRemoteAction<T>)

Functions

alsoAsync

fun <T> PNFuture<T>.alsoAsync(action: (T) -> PNFuture<*>): PNFuture<T>

Execute a second PNFuture after this PNFuture completes successfully, and return the original value of this PNFuture after the second PNFuture completes successfully.

async

open override fun async(callback: Consumer<Result>)

catch

fun <T> PNFuture<T>.catch(action: (Exception) -> Result<T>): PNFuture<T>

checkpoint

@Synchronized

fun checkpoint(): ComposableRemoteAction<T, U>

map

fun <T, U> ExtendedRemoteAction<T>.map(function: (T) -> U): ExtendedRemoteAction

operationType

open override fun operationType(): PNOperationType

remember

fun <T> PNFuture<T>.remember(): PNFuture<T>

retry

@Synchronized

open override fun retry()

silentCancel

@Synchronized

open override fun silentCancel()

sync

open override fun sync(): U

then

fun <Y> then(factory: (U) -> ExtendedRemoteAction<Y>): ComposableRemoteAction<U, Y>

then

fun <T, U> PNFuture<T>.then(action: (T) -> U): PNFuture

thenAsync

fun <T, U> PNFuture<T>.thenAsync(action: (T) -> PNFuture): PNFuture