vertx / io.vertx.ext.cluster.infinispan / InfinispanAsyncMap

InfinispanAsyncMap

interface InfinispanAsyncMap<K : Any, V : Any>

Extensions to the generic AsyncMap.

Author
Thomas Segismont

Functions

entryStream

abstract fun entryStream(): ReadStream<MutableEntry<K, V>>

Get the entries of the map as a ReadStream.

The stream will be automatically closed if it fails or ends. Otherwise you must set a null data handler after usage to avoid leaking resources.

keyStream

abstract fun keyStream(): ReadStream<K>

Get the keys of the map as a ReadStream.

The stream will be automatically closed if it fails or ends. Otherwise you must set a null data handler after usage to avoid leaking resources.

unwrap

open static fun <K : Any, V : Any> unwrap(asyncMap: AsyncMap<Any, Any>): InfinispanAsyncMap<K, V>

Unwraps a generic AsyncMap to an InfinispanAsyncMap.

valueStream

abstract fun valueStream(): ReadStream<V>

Get the values of the map as a ReadStream.

The stream will be automatically closed if it fails or ends. Otherwise you must set a null data handler after usage to avoid leaking resources.