Class RmWatcher.ContinueFromEnd

java.lang.Object

io.confluent.rm.api.RmWatcher.ContinueFromEnd

All Implemented Interfaces:

RmWatcher.InitializationStrategy

Enclosing interface:

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

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

Start a watch stream at its tail. This does not load a snapshot.

Constructor Summary

Constructors

Constructor	Description
ContinueFromEnd()

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

ContinueFromEnd

public ContinueFromEnd()

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