docs: @Subscribe
      public void complete(ReplicationCompleted rc) {
          mHandler.post(new Runnable() {
              @Override
              public void run() {
                  if (mListener != null) {
                      mListener.replicationComplete();
                  }
              }
          });
      }