rx - rx

Scala.Rx is an experimental change propagation library for Scala. Scala.Rx gives you Reactive variables (Rxs), which are smart variables who auto-update themselves when the values they depend on change. The underlying implementation is push-based FRP based on the ideas in Deprecating the Observer Pattern.

A simple example which demonstrates its usage is:

import rx._
val a = Var(1); val b = Var(2)
val c = Rx{ a() + b() }
println(c()) // 3
a() = 4
println(c()) // 6

See the github page for more instructions on how to use this package, or browse the classes on the left.

Linear Supertypes

AnyRef, Any

Type Members

implicit class AsyncRx[T] extends AnyRef

Provides extension methods on Rx[Future]s.
trait Emitter[+T] extends Node

Something that emits pings.
class Obs extends Reactor[Any]

An Obs is something that produces side-effects when the source Rx changes.
trait Propagator[P] extends AnyRef

A Propagator is an object which performs a propagation wave over the Scala.
trait Reactor[-T] extends Node

Something that can receive pings and react to them in some way.
trait Rx[+T] extends Emitter[T] with RxMethods[T]

An Rx is a value that can change over time, emitting pings whenever it changes to notify any dependent Rxs that they need to update.
class Var[T] extends Rx[T]

A Var is an Rx which can be changed manually via assignment.

rx

package rx

Type Members

implicit class AsyncRx[T] extends AnyRef

trait Emitter[+T] extends Node

class Obs extends Reactor[Any]

trait Propagator[P] extends AnyRef

trait Reactor[-T] extends Node

trait Rx[+T] extends Emitter[T] with RxMethods[T]

class Var[T] extends Rx[T]

Value Members

object Obs

object Propagator

object Rx

object Var

Inherited from AnyRef

Inherited from Any

Ungrouped