Package org.infinispan.xsite.statetransfer

Interface XSiteStatePushTask

public interface XSiteStatePushTask
Sends local cluster state to remote site.
Since:
12.0
Author:
Pedro Ruivo

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    execute(io.reactivex.rxjava3.core.Flowable<XSiteState> flowable, CompletionStage<Void> delayer)
    Perform the state transfer with the state from Flowable.

  • Method Details

    • execute

      void execute(io.reactivex.rxjava3.core.Flowable<XSiteState> flowable, CompletionStage<Void> delayer)
      Perform the state transfer with the state from Flowable.

      The Flowable can only be iterated after delayer is completed.

      Parameters:
      flowable - The Flowable with the local cluster state.
      delayer - A CompletionStage which is completed when it is allowed to start sending the state.