Package org.apache.curator.x.async

Interface AsyncCuratorFramework

All Superinterfaces:

AsyncCuratorFrameworkDsl, WatchableAsyncCuratorFramework

All Known Implementing Classes:

AsyncCuratorFrameworkImpl

public interface AsyncCuratorFramework
extends AsyncCuratorFrameworkDsl

Zookeeper framework-style client that returns composable async operations that implement CompletionStage

Method Summary

Modifier and Type	Method	Description
CuratorFramework	unwrap()	Returns the client that was originally passed to wrap(org.apache.curator.framework.CuratorFramework)
AsyncCuratorFrameworkDsl	with(UnaryOperator<CuratorEvent> resultFilter, UnaryOperator<org.apache.zookeeper.WatchedEvent> watcherFilter)	Returns a facade that adds the the given filters to all background operations and watchers.
AsyncCuratorFrameworkDsl	with(UnhandledErrorListener listener)	Returns a facade that adds the given UnhandledErrorListener to all background operations
AsyncCuratorFrameworkDsl	with(UnhandledErrorListener listener, UnaryOperator<CuratorEvent> resultFilter, UnaryOperator<org.apache.zookeeper.WatchedEvent> watcherFilter)	Set any combination of listener or filters
AsyncCuratorFrameworkDsl	with(WatchMode mode)	Returns a facade that changes how watchers are set when AsyncCuratorFrameworkDsl.watched() is called
AsyncCuratorFrameworkDsl	with(WatchMode mode, UnhandledErrorListener listener, UnaryOperator<CuratorEvent> resultFilter, UnaryOperator<org.apache.zookeeper.WatchedEvent> watcherFilter)	Set any combination of listener, filters or watch mode
static AsyncCuratorFramework	wrap(CuratorFramework client)	Takes an old-style Curator instance and returns a new async instance that wraps it.

Methods inherited from interface org.apache.curator.x.async.api.AsyncCuratorFrameworkDsl

addWatch, create, delete, getACL, reconfig, removeWatches, setACL, setData, sync, transaction, transactionOp, watched

Methods inherited from interface org.apache.curator.x.async.api.WatchableAsyncCuratorFramework

checkExists, getChildren, getConfig, getData

Method Details

wrap

static AsyncCuratorFramework wrap(CuratorFramework client)

Takes an old-style Curator instance and returns a new async instance that wraps it. Note: the instance must have been created through a chain that leads back to CuratorFrameworkFactory. i.e. you can have derived instances such as WatcherRemoveCuratorFramework etc. but the original client must have been created by the Factory.

Parameters:

client - instance to wrap

Returns:

wrapped instance

unwrap

CuratorFramework unwrap()

Returns the client that was originally passed to wrap(org.apache.curator.framework.CuratorFramework)

Returns:

original client

with

AsyncCuratorFrameworkDsl with(WatchMode mode)

Returns a facade that changes how watchers are set when AsyncCuratorFrameworkDsl.watched() is called

Parameters:

mode - watch mode to use for subsequent calls to AsyncCuratorFrameworkDsl.watched()

Returns:

facade

with

AsyncCuratorFrameworkDsl with(UnhandledErrorListener listener)

Returns a facade that adds the given UnhandledErrorListener to all background operations

Parameters:

listener - lister to use

Returns:

facade

with

AsyncCuratorFrameworkDsl with(UnaryOperator<CuratorEvent> resultFilter,
 UnaryOperator<org.apache.zookeeper.WatchedEvent> watcherFilter)

Returns a facade that adds the the given filters to all background operations and watchers. resultFilter will get called for every background callback. watcherFilter will get called for every watcher. The filters can return new versions or unchanged versions of the arguments.

Parameters:

resultFilter - filter to use or null

watcherFilter - filter to use or null

Returns:

facade

with

AsyncCuratorFrameworkDsl with(UnhandledErrorListener listener,
 UnaryOperator<CuratorEvent> resultFilter,
 UnaryOperator<org.apache.zookeeper.WatchedEvent> watcherFilter)

Set any combination of listener or filters

Parameters:

listener - lister to use or null

resultFilter - filter to use or null

watcherFilter - filter to use or null

Returns:

facade

See Also:

• with(java.util.function.UnaryOperator, java.util.function.UnaryOperator)
• with(org.apache.curator.framework.api.UnhandledErrorListener)

with

AsyncCuratorFrameworkDsl with(WatchMode mode,
 UnhandledErrorListener listener,
 UnaryOperator<CuratorEvent> resultFilter,
 UnaryOperator<org.apache.zookeeper.WatchedEvent> watcherFilter)

Set any combination of listener, filters or watch mode

Parameters:

mode - watch mode to use for subsequent calls to AsyncCuratorFrameworkDsl.watched() (cannot be null)

listener - lister to use or null

resultFilter - filter to use or null

watcherFilter - filter to use or null

Returns:

facade

See Also:

• with(WatchMode)
• with(java.util.function.UnaryOperator, java.util.function.UnaryOperator)
• with(org.apache.curator.framework.api.UnhandledErrorListener)