c

riff.monix

MonixClient

case class MonixClient[A](inputSubscriber: Observer[RaftMessage[A]], raftNodeLogResults: Observable[LogAppendResult])(implicit evidence$1: ClassTag[A], sched: Scheduler) extends RaftClient[Observable, A] with LowPriorityRiffMonixImplicits with Product with Serializable

An implementation of RaftClient which will push incoming data into the input for the node (i.e. the inputSubscriber)

inputSubscriber

the input into a riff.raft.node.RaftMessageHandler

raftNodeLogResults

the output of the log to which the inputSubscriber feeds in order to detect overwritten log entries

Linear Supertypes
Serializable, Serializable, Product, Equals, LowPriorityRiffMonixImplicits, RaftClient[Observable, A], AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. MonixClient
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. LowPriorityRiffMonixImplicits
  7. RaftClient
  8. AnyRef
  9. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new MonixClient(inputSubscriber: Observer[RaftMessage[A]], raftNodeLogResults: Observable[LogAppendResult])(implicit arg0: ClassTag[A], sched: Scheduler)

    inputSubscriber

    the input into a riff.raft.node.RaftMessageHandler

    raftNodeLogResults

    the output of the log to which the inputSubscriber feeds in order to detect overwritten log entries

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def append(data: Array[A]): Observable[AppendStatus]
    Definition Classes
    MonixClient → RaftClient
  5. final def append(data: A, theRest: A*)(implicit classTag: ClassTag[A]): Observable[AppendStatus]
    Definition Classes
    RaftClient
  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  10. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  11. val inputSubscriber: Observer[RaftMessage[A]]
  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  14. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  15. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  16. implicit def observableAsPublisher(implicit scheduler: Scheduler): AsPublisher[Observable]
    Definition Classes
    LowPriorityRiffMonixImplicits
  17. implicit def observerAsSubscriber(implicit scheduler: Scheduler): AsSubscriber[Observer]
    Definition Classes
    LowPriorityRiffMonixImplicits
  18. val raftNodeLogResults: Observable[LogAppendResult]
  19. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  20. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  21. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  22. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from LowPriorityRiffMonixImplicits

Inherited from RaftClient[Observable, A]

Inherited from AnyRef

Inherited from Any

Ungrouped