Class RmWatcher.ContinueWithToken

java.lang.Object

io.confluent.rm.api.RmWatcher.ContinueWithToken

All Implemented Interfaces:

RmWatcher.InitializationStrategy

Enclosing interface:

RmWatcher<T extends io.confluent.resourcemanager.api.model.HasMetadata>

public static class RmWatcher.ContinueWithToken
extends Object
implements RmWatcher.InitializationStrategy

Continue a watch stream from a token. The token cannot be null or an empty string.

Constructor Summary

Constructors

Constructor	Description
ContinueWithToken(String continueToken)

Method Summary

Modifier and Type	Method	Description
void	accept(BiConsumer<String,Boolean> tokenAndSnapshotConsumer)	Apply the given consumer with the appropriate continueToken and includeSnapshot values.

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ContinueWithToken

public ContinueWithToken(String continueToken)

Method Details

accept

public void accept(BiConsumer<String,Boolean> tokenAndSnapshotConsumer)

Description copied from interface: RmWatcher.InitializationStrategy

Apply the given consumer with the appropriate continueToken and includeSnapshot values.

Specified by:

accept in interface RmWatcher.InitializationStrategy