code: public void onSuccess(StreamState state)
      {
          logger.info(String.format("[repair #%s] streaming task succeed, returning response to %s", desc.sessionId, request.initiator));
          MessagingService.instance().sendOneWay(new SyncComplete(desc, request.src, request.dst, true).createMessage(), request.initiator);
      }
docs: If we succeeded on both stream in and out, reply back to the initiator.