trait
Propagator[P] extends AnyRef
Abstract Value Members
-
abstract
def
propagate(pings: Set[(Emitter[_], Reactor[_])]): P
Concrete Value Members
-
final
def
!=(arg0: AnyRef): Boolean
-
final
def
!=(arg0: Any): Boolean
-
final
def
##(): Int
-
final
def
==(arg0: AnyRef): Boolean
-
final
def
==(arg0: Any): Boolean
-
final
def
asInstanceOf[T0]: T0
-
def
clone(): AnyRef
-
final
def
eq(arg0: AnyRef): Boolean
-
def
equals(arg0: Any): Boolean
-
def
finalize(): Unit
-
final
def
getClass(): Class[_]
-
def
hashCode(): Int
-
final
def
isInstanceOf[T0]: Boolean
-
final
def
ne(arg0: AnyRef): Boolean
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
def
toString(): String
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit
Inherited from AnyRef
Inherited from Any
A Propagator is an object which performs a propagation wave over the Scala.Rx dataflow graph. It is parametrized on the type P which it returns after performing a propagation wave. The two existing Propagators are:
Propagator.Immediate (
Propagator[Unit]), which runs the propagation wave immediately and returns Unit when it is complete.Propagator.ExecContext (
Propagator[Future[Unit]]), which runs the propagation wave on the givenExecutionContextand returns aFuture[Unit]representing the completion of the propagation wave.It is conceivable that custom propagators could use the return type
Pto return other things, e.g. the number of updates performed, or the number of re-tries in that propagation wave. That is up to the implementer to decide.the type that the
propagate()function returns