Class RmWatcher.LoadSnapshot

java.lang.Object

io.confluent.rm.api.RmWatcher.LoadSnapshot

All Implemented Interfaces:

RmWatcher.InitializationStrategy

Enclosing interface:

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

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

Start a watch stream with a full snapshot.

Constructor Summary

Constructors

Constructor	Description
LoadSnapshot()

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

LoadSnapshot

public LoadSnapshot()

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