Interface RmWatcher.InitializationStrategy

All Known Implementing Classes:
RmWatcher.ContinueFromEnd, RmWatcher.ContinueWithToken, RmWatcher.LoadSnapshot
Enclosing interface:
RmWatcher<T extends io.confluent.resourcemanager.api.model.HasMetadata>
public static interface RmWatcher.InitializationStrategy
Strategy for how the watch stream is initialized

  • Method Summary

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

  • Method Details

    • accept

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