Class ReadAggregator

    • Method Detail

      • result

        public scala.Option<akka.cluster.ddata.Replicator.Internal.DataEnvelope> result()
      • result_$eq

        public void result_$eq​(scala.Option<akka.cluster.ddata.Replicator.Internal.DataEnvelope> x$1)
      • readMsg

        public akka.cluster.ddata.Replicator.Internal.Read readMsg()
      • preStart

        public void preStart()
        Description copied from interface: Actor
        User overridable callback.

        Is called when an Actor is started. Actors are automatically started asynchronously when created. Empty default implementation.
        Specified by:
        preStart in interface Actor
      • receive

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive()
        Description copied from interface: Actor
        Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
        Specified by:
        receive in interface Actor
        Returns:
        (undocumented)
      • reply

        public void reply​(boolean ok)
      • waitReadRepairAck

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> waitReadRepairAck​(akka.cluster.ddata.Replicator.Internal.DataEnvelope envelope)