concurrent
Module Contents
alltypes
Module Contents
interface AsyncCompletion
Module Contents
abstract fun accept(consumer: Consumer<in Throwable!>!): AsyncCompletion!
open static fun allOf(vararg cs: AsyncCompletion!): AsyncCompletion!
open static fun allOf(cs: MutableCollection<AsyncCompletion!>!): AsyncCompletion!
open static fun allOf(cs: Stream<AsyncCompletion!>!): AsyncCompletion!
abstract fun cancel(): Boolean
open static fun completed(): AsyncCompletion!
static val COMPLETED: AsyncCompletion!
open static fun exceptional(ex: Throwable!): AsyncCompletion!
abstract fun exceptionally(consumer: Consumer<in Throwable!>!): AsyncCompletion!
open static fun executeBlocking(action: Runnable!): AsyncCompletion!
open static fun executeBlocking(executor: Executor!, action: Runnable!): AsyncCompletion!
open static fun executeBlocking(vertx: Vertx!, action: Runnable!): AsyncCompletion!
open static fun executeBlocking(executor: WorkerExecutor!, action: Runnable!): AsyncCompletion!
abstract fun <U : Any!> handle(fn: Function<in Throwable!, out U>!): AsyncResult<U>!
open static fun incomplete(): CompletableAsyncCompletion!
abstract fun isCancelled(): Boolean
abstract fun isCompletedExceptionally(): Boolean
abstract fun isDone(): Boolean
abstract fun join(): Unit
abstract fun join(timeout: Long, unit: TimeUnit!): Unit
open static fun runOnContext(vertx: Vertx!, fn: Supplier<out AsyncCompletion!>!): AsyncCompletion!
open static fun runOnContext(vertx: Vertx!, action: Runnable!): AsyncCompletion!
abstract fun <U : Any!> then(fn: Supplier<out AsyncResult<U>!>!): AsyncResult<U>!
abstract fun <U : Any!, V : Any!> thenApply(other: AsyncResult<out U>!, fn: Function<in U, out V>!): AsyncResult<V>!
abstract fun thenCombine(other: AsyncCompletion!): AsyncCompletion!
abstract fun thenCompose(fn: Supplier<out AsyncCompletion!>!): AsyncCompletion!
abstract fun <U : Any!> thenConsume(other: AsyncResult<out U>!, consumer: Consumer<in U>!): AsyncCompletion!
abstract fun thenRun(runnable: Runnable!): AsyncCompletion!
abstract fun <U : Any!> thenSchedule(vertx: Vertx!, fn: Supplier<out AsyncResult<U>!>!): AsyncResult<U>!
abstract fun thenScheduleBlockingRun(vertx: Vertx!, runnable: Runnable!): AsyncCompletion!
abstract fun thenScheduleBlockingRun(executor: WorkerExecutor!, runnable: Runnable!): AsyncCompletion!
abstract fun thenScheduleRun(vertx: Vertx!, runnable: Runnable!): AsyncCompletion!
abstract fun <U : Any!> thenSupply(supplier: Supplier<out U>!): AsyncResult<U>!
abstract fun <U : Any!> thenSupply(vertx: Vertx!, supplier: Supplier<out U>!): AsyncResult<U>!
abstract fun toFuture(): Future<Void!>!
abstract fun whenComplete(consumer: Consumer<in Throwable!>!): AsyncCompletion!
interface AsyncResult<T : Any!>
Module Contents
abstract fun accept(consumer: BiConsumer<in T, Throwable!>!): AsyncCompletion!
open static fun allOf(vararg rs: AsyncResult<*>!): AsyncCompletion!
open static fun allOf(rs: MutableCollection<out AsyncResult<*>!>!): AsyncCompletion!
open static fun allOf(rs: Stream<out AsyncResult<*>!>!): AsyncCompletion!
abstract fun cancel(): Boolean
open static fun <T : Any!> combine(rs: MutableCollection<out AsyncResult<out T>!>!): AsyncResult<MutableList<T>!>!
open static fun <T : Any!> combine(rs: Stream<out AsyncResult<out T>!>!): AsyncResult<MutableList<T>!>!
open static fun <T : Any!> completed(@Nullable value: T?): AsyncResult<T>!
open static fun <T : Any!> exceptional(ex: Throwable!): AsyncResult<T>!
abstract fun exceptionally(fn: Function<Throwable!, out T>!): AsyncResult<T>!
open static fun <T : Any!> executeBlocking(fn: Supplier<T>!): AsyncResult<T>!
open static fun <T : Any!> executeBlocking(executor: Executor!, fn: Supplier<T>!): AsyncResult<T>!
open static fun <T : Any!> executeBlocking(vertx: Vertx!, fn: Supplier<T>!): AsyncResult<T>!
open static fun <T : Any!> executeBlocking(executor: WorkerExecutor!, fn: Supplier<T>!): AsyncResult<T>!
@Nullable abstract fun get(): T?
@Nullable abstract fun get(timeout: Long, unit: TimeUnit!): T?
abstract fun <U : Any!> handle(fn: BiFunction<in T, Throwable!, out U>!): AsyncResult<U>!
open static fun <T : Any!> incomplete(): CompletableAsyncResult<T>!
abstract fun isCancelled(): Boolean
abstract fun isCompletedExceptionally(): Boolean
abstract fun isDone(): Boolean
open static fun <T : Any!> runOnContext(vertx: Vertx!, fn: Supplier<out AsyncResult<T>!>!): AsyncResult<T>!
abstract fun <U : Any!> then(fn: Function<in T, out AsyncResult<U>!>!): AsyncResult<U>!
abstract fun thenAccept(consumer: Consumer<in T>!): AsyncCompletion!
abstract fun <U : Any!> thenAcceptBoth(other: AsyncResult<out U>!, consumer: BiConsumer<in T, in U>!): AsyncCompletion!
abstract fun <U : Any!> thenApply(fn: Function<in T, out U>!): AsyncResult<U>!
abstract fun <U : Any!, V : Any!> thenCombine(other: AsyncResult<out U>!, fn: BiFunction<in T, in U, out V>!): AsyncResult<V>!
abstract fun thenCompose(fn: Function<in T, out AsyncCompletion!>!): AsyncCompletion!
abstract fun thenRun(runnable: Runnable!): AsyncCompletion!
abstract fun <U : Any!> thenSchedule(vertx: Vertx!, fn: Function<in T, out AsyncResult<U>!>!): AsyncResult<U>!
abstract fun <U : Any!> thenScheduleApply(vertx: Vertx!, fn: Function<in T, out U>!): AsyncResult<U>!
abstract fun <U : Any!> thenScheduleBlockingApply(vertx: Vertx!, fn: Function<in T, out U>!): AsyncResult<U>!
abstract fun <U : Any!> thenScheduleBlockingApply(executor: WorkerExecutor!, fn: Function<in T, out U>!): AsyncResult<U>!
abstract fun thenScheduleBlockingRun(vertx: Vertx!, runnable: Runnable!): AsyncCompletion!
abstract fun thenScheduleBlockingRun(executor: WorkerExecutor!, runnable: Runnable!): AsyncCompletion!
abstract fun thenScheduleRun(vertx: Vertx!, runnable: Runnable!): AsyncCompletion!
abstract fun whenComplete(action: BiConsumer<in T, in Throwable!>!): AsyncResult<T>!
class AtomicSlotMap<K : Comparable<Any?>!, V : Any!>
interface CompletableAsyncCompletion : AsyncCompletion
interface CompletableAsyncResult<T : Any!> : AsyncResult<T>
class ExpiringMap<K : Any!, V : Any!> : MutableMap<K, V>
Module Contents
ExpiringMap()
fun clear(): Unit
fun compute(key: K, remappingFunction: BiFunction<in K, in V?, out V?>): V?
fun computeIfAbsent(key: K, mappingFunction: Function<in K, out V>): V
fun computeIfPresent(key: K, remappingFunction: BiFunction<in K, in V, out V?>): V?
fun containsKey(key: K): Boolean
fun containsValue(value: V): Boolean
val entries: MutableSet<MutableEntry<K, V>>
fun equals(other: Any?): Boolean
fun forEach(action: BiConsumer<in K, in V>): Unit
@Nullable fun get(key: K): V?
fun getOrDefault(key: K, defaultValue: V): V
fun hashCode(): Int
fun isEmpty(): Boolean
val keys: MutableSet<K>
fun merge(key: K, value: V, remappingFunction: BiFunction<in V, in V, out V?>): V?
fun purgeExpired(): Long
@Nullable fun put(key: K, value: V): V?
@Nullable fun put(key: K, value: V, expiry: Long): V?
@Nullable fun put(key: K, value: V, expiry: Long, @Nullable expiryListener: BiConsumer<K, V>?): V?
fun putAll(from: Map<out K, V>): Unit
@Nullable fun putIfAbsent(key: K, value: V): V?
@Nullable fun putIfAbsent(key: K, value: V, expiry: Long): V?
@Nullable fun putIfAbsent(key: K, value: V, expiry: Long, @Nullable expiryListener: BiConsumer<K, V>?): V?
fun remove(key: K): V?
fun remove(key: K, value: V): Boolean
fun replace(key: K, value: V): V?
fun replace(key: K, oldValue: V, newValue: V): Boolean
fun replaceAll(function: BiFunction<in K, in V, out V>): Unit
val size: Int
val values: MutableCollection<V>
class ExpiringSet<E : Any!> : MutableSet<E>
package org.apache.tuweni.concurrent
Module Contents
interface AsyncCompletion
Module Contents
abstract fun accept(consumer: Consumer<in Throwable!>!): AsyncCompletion!
open static fun allOf(vararg cs: AsyncCompletion!): AsyncCompletion!
open static fun allOf(cs: MutableCollection<AsyncCompletion!>!): AsyncCompletion!
open static fun allOf(cs: Stream<AsyncCompletion!>!): AsyncCompletion!
abstract fun cancel(): Boolean
open static fun completed(): AsyncCompletion!
static val COMPLETED: AsyncCompletion!
open static fun exceptional(ex: Throwable!): AsyncCompletion!
abstract fun exceptionally(consumer: Consumer<in Throwable!>!): AsyncCompletion!
open static fun executeBlocking(action: Runnable!): AsyncCompletion!
open static fun executeBlocking(executor: Executor!, action: Runnable!): AsyncCompletion!
open static fun executeBlocking(vertx: Vertx!, action: Runnable!): AsyncCompletion!
open static fun executeBlocking(executor: WorkerExecutor!, action: Runnable!): AsyncCompletion!
abstract fun <U : Any!> handle(fn: Function<in Throwable!, out U>!): AsyncResult<U>!
open static fun incomplete(): CompletableAsyncCompletion!
abstract fun isCancelled(): Boolean
abstract fun isCompletedExceptionally(): Boolean
abstract fun isDone(): Boolean
abstract fun join(): Unit
abstract fun join(timeout: Long, unit: TimeUnit!): Unit
open static fun runOnContext(vertx: Vertx!, fn: Supplier<out AsyncCompletion!>!): AsyncCompletion!
open static fun runOnContext(vertx: Vertx!, action: Runnable!): AsyncCompletion!
abstract fun <U : Any!> then(fn: Supplier<out AsyncResult<U>!>!): AsyncResult<U>!
abstract fun <U : Any!, V : Any!> thenApply(other: AsyncResult<out U>!, fn: Function<in U, out V>!): AsyncResult<V>!
abstract fun thenCombine(other: AsyncCompletion!): AsyncCompletion!
abstract fun thenCompose(fn: Supplier<out AsyncCompletion!>!): AsyncCompletion!
abstract fun <U : Any!> thenConsume(other: AsyncResult<out U>!, consumer: Consumer<in U>!): AsyncCompletion!
abstract fun thenRun(runnable: Runnable!): AsyncCompletion!
abstract fun <U : Any!> thenSchedule(vertx: Vertx!, fn: Supplier<out AsyncResult<U>!>!): AsyncResult<U>!
abstract fun thenScheduleBlockingRun(vertx: Vertx!, runnable: Runnable!): AsyncCompletion!
abstract fun thenScheduleBlockingRun(executor: WorkerExecutor!, runnable: Runnable!): AsyncCompletion!
abstract fun thenScheduleRun(vertx: Vertx!, runnable: Runnable!): AsyncCompletion!
abstract fun <U : Any!> thenSupply(supplier: Supplier<out U>!): AsyncResult<U>!
abstract fun <U : Any!> thenSupply(vertx: Vertx!, supplier: Supplier<out U>!): AsyncResult<U>!
abstract fun toFuture(): Future<Void!>!
abstract fun whenComplete(consumer: Consumer<in Throwable!>!): AsyncCompletion!
interface AsyncResult<T : Any!>
Module Contents
abstract fun accept(consumer: BiConsumer<in T, Throwable!>!): AsyncCompletion!
open static fun allOf(vararg rs: AsyncResult<*>!): AsyncCompletion!
open static fun allOf(rs: MutableCollection<out AsyncResult<*>!>!): AsyncCompletion!
open static fun allOf(rs: Stream<out AsyncResult<*>!>!): AsyncCompletion!
abstract fun cancel(): Boolean
open static fun <T : Any!> combine(rs: MutableCollection<out AsyncResult<out T>!>!): AsyncResult<MutableList<T>!>!
open static fun <T : Any!> combine(rs: Stream<out AsyncResult<out T>!>!): AsyncResult<MutableList<T>!>!
open static fun <T : Any!> completed(@Nullable value: T?): AsyncResult<T>!
open static fun <T : Any!> exceptional(ex: Throwable!): AsyncResult<T>!
abstract fun exceptionally(fn: Function<Throwable!, out T>!): AsyncResult<T>!
open static fun <T : Any!> executeBlocking(fn: Supplier<T>!): AsyncResult<T>!
open static fun <T : Any!> executeBlocking(executor: Executor!, fn: Supplier<T>!): AsyncResult<T>!
open static fun <T : Any!> executeBlocking(vertx: Vertx!, fn: Supplier<T>!): AsyncResult<T>!
open static fun <T : Any!> executeBlocking(executor: WorkerExecutor!, fn: Supplier<T>!): AsyncResult<T>!
@Nullable abstract fun get(): T?
@Nullable abstract fun get(timeout: Long, unit: TimeUnit!): T?
abstract fun <U : Any!> handle(fn: BiFunction<in T, Throwable!, out U>!): AsyncResult<U>!
open static fun <T : Any!> incomplete(): CompletableAsyncResult<T>!
abstract fun isCancelled(): Boolean
abstract fun isCompletedExceptionally(): Boolean
abstract fun isDone(): Boolean
open static fun <T : Any!> runOnContext(vertx: Vertx!, fn: Supplier<out AsyncResult<T>!>!): AsyncResult<T>!
abstract fun <U : Any!> then(fn: Function<in T, out AsyncResult<U>!>!): AsyncResult<U>!
abstract fun thenAccept(consumer: Consumer<in T>!): AsyncCompletion!
abstract fun <U : Any!> thenAcceptBoth(other: AsyncResult<out U>!, consumer: BiConsumer<in T, in U>!): AsyncCompletion!
abstract fun <U : Any!> thenApply(fn: Function<in T, out U>!): AsyncResult<U>!
abstract fun <U : Any!, V : Any!> thenCombine(other: AsyncResult<out U>!, fn: BiFunction<in T, in U, out V>!): AsyncResult<V>!
abstract fun thenCompose(fn: Function<in T, out AsyncCompletion!>!): AsyncCompletion!
abstract fun thenRun(runnable: Runnable!): AsyncCompletion!
abstract fun <U : Any!> thenSchedule(vertx: Vertx!, fn: Function<in T, out AsyncResult<U>!>!): AsyncResult<U>!
abstract fun <U : Any!> thenScheduleApply(vertx: Vertx!, fn: Function<in T, out U>!): AsyncResult<U>!
abstract fun <U : Any!> thenScheduleBlockingApply(vertx: Vertx!, fn: Function<in T, out U>!): AsyncResult<U>!
abstract fun <U : Any!> thenScheduleBlockingApply(executor: WorkerExecutor!, fn: Function<in T, out U>!): AsyncResult<U>!
abstract fun thenScheduleBlockingRun(vertx: Vertx!, runnable: Runnable!): AsyncCompletion!
abstract fun thenScheduleBlockingRun(executor: WorkerExecutor!, runnable: Runnable!): AsyncCompletion!
abstract fun thenScheduleRun(vertx: Vertx!, runnable: Runnable!): AsyncCompletion!
abstract fun whenComplete(action: BiConsumer<in T, in Throwable!>!): AsyncResult<T>!
class AtomicSlotMap<K : Comparable<Any?>!, V : Any!>
interface CompletableAsyncCompletion : AsyncCompletion
interface CompletableAsyncResult<T : Any!> : AsyncResult<T>
class ExpiringMap<K : Any!, V : Any!> : MutableMap<K, V>
Module Contents
ExpiringMap()
fun clear(): Unit
fun compute(key: K, remappingFunction: BiFunction<in K, in V?, out V?>): V?
fun computeIfAbsent(key: K, mappingFunction: Function<in K, out V>): V
fun computeIfPresent(key: K, remappingFunction: BiFunction<in K, in V, out V?>): V?
fun containsKey(key: K): Boolean
fun containsValue(value: V): Boolean
val entries: MutableSet<MutableEntry<K, V>>
fun equals(other: Any?): Boolean
fun forEach(action: BiConsumer<in K, in V>): Unit
@Nullable fun get(key: K): V?
fun getOrDefault(key: K, defaultValue: V): V
fun hashCode(): Int
fun isEmpty(): Boolean
val keys: MutableSet<K>
fun merge(key: K, value: V, remappingFunction: BiFunction<in V, in V, out V?>): V?
fun purgeExpired(): Long
@Nullable fun put(key: K, value: V): V?
@Nullable fun put(key: K, value: V, expiry: Long): V?
@Nullable fun put(key: K, value: V, expiry: Long, @Nullable expiryListener: BiConsumer<K, V>?): V?
fun putAll(from: Map<out K, V>): Unit
@Nullable fun putIfAbsent(key: K, value: V): V?
@Nullable fun putIfAbsent(key: K, value: V, expiry: Long): V?
@Nullable fun putIfAbsent(key: K, value: V, expiry: Long, @Nullable expiryListener: BiConsumer<K, V>?): V?
fun remove(key: K): V?
fun remove(key: K, value: V): Boolean
fun replace(key: K, value: V): V?
fun replace(key: K, oldValue: V, newValue: V): Boolean
fun replaceAll(function: BiFunction<in K, in V, out V>): Unit
val size: Int
val values: MutableCollection<V>
class ExpiringSet<E : Any!> : MutableSet<E>