JobFuture

Wraps a job closure in a future. The job is not invoked until await is called. The jobInput is passed as the only argument to job.

class JobFuture<T, V>(job: (T) -> V, jobInput: T) : Future<V>

Parameters

the type of the job

the output of the job

JobFuture

common

the type of the job

fun <T, V> JobFuture(job: (T) -> V, jobInput: T)

await

common

Consume the future value in code as input. This method may or may not block the calling thread depending upon the implementation.

val future: Future<T> = // some api which returns a Future<T>
val value: R = future.await() // blocks until future completes

open override fun await(): V

equals

common

open operator override fun equals(other: Any?): Boolean

hashCode

common

open override fun hashCode(): Int

toString

common

open override fun toString(): String

isCompleted

common

Returns true if the future has completed and is ready to await.

open override var isCompleted: Boolean

job

common

the job to be executed in future

val job: (T) -> V

jobInput

common

the only argument passed to the job