GetFuture

open class GetFuture<T> : Future

Base class for all futures that get something. Get one element.

In the subclasses, you will get easy semantics.

onGet is called when a successful response has been received (not null)
onNotFound is called, when a response has been received, but the answer is null, indicating that the searched key was not found

The subclasses differ by these orthogonal concepts:

Do you get one or multiple things? Multiple things have the suffix All
In your method, do you transform the response from the DHT before you return it? Transformed responses have the suffix Custom
E.g., you get a UserId from the DHT, but you want to return a User

GetFuture(futureGet: FutureGet)

Base class for all futures that get something. Get one element.

val futureGet: FutureGet

base TomP2P FutureGet

val baseFuture: BaseFuture

base TomP2P BaseFuture

onGet	`open fun onGet(emitter: (data: T) -> Unit): Unit` A single element has been found
onNotFound	`open fun onNotFound(emitter: () -> Unit): Unit` A single element has not been found

await	`fun await(): Future` Await async operation to end
awaitListeners	`fun awaitListeners(): Future` Await all registered listeners
onComplete	`fun onComplete(emitter: () -> Unit): Unit` An operation has completed. Check net.tomp2p.futures.BaseFuture.onComplete for the full semantics
onFailure	`fun onFailure(emitter: (failedReason: String) -> Unit): Unit` The connection has failed. Check net.tomp2p.futures.BaseFuture.onFailure for the full semantics
onSuccess	`fun onSuccess(emitter: () -> Unit): Unit` A response has been received. Check net.tomp2p.futures.BaseFuture.onSuccess for the full semantics

GetAllCustomFuture	`class GetAllCustomFuture<T, U> : GetFuture<T>` Get multiple elements and transform them
GetCustomFuture	`open class GetCustomFuture<T, U> : GetFuture<T>` Get one element and transform it.