react

Class AbstractValue<T>

java.lang.Object

react.Reactor

react.AbstractValue<T>

All Implemented Interfaces:

ValueView<T>

Direct Known Subclasses:

Value

public abstract class AbstractValue<T>
extends Reactor
implements ValueView<T>

Handles the machinery of connecting listeners to a value and notifying them, without exposing a public interface for updating the value. This can be used by libraries which wish to provide observable values, but must manage the maintenance and distribution of value updates themselves (so that they may send them over the network, for example).

Nested Class Summary

Nested classes/interfaces inherited from class react.Reactor

Reactor.RListener

Nested classes/interfaces inherited from interface react.ValueView

ValueView.Listener<T>

Constructor Summary

Constructors

Constructor and Description
AbstractValue()

Method Summary

Modifier and Type	Method and Description
SignalView<T>	changes() Returns a signal that is emitted whenever this value changes.
Connection	connect(SignalView.Listener<? super T> listener) Connects the supplied listener to this value, such that it will be notified when this value changes.
Connection	connect(Slot<? super T> slot) Connects the supplied listener to this value, such that it will be notified when this value changes.
Connection	connect(ValueView.Listener<? super T> listener) Connects the supplied listener to this value, such that it will be notified when this value changes.
Connection	connectNotify(SignalView.Listener<? super T> listener) Connects the supplied listener to this value, such that it will be notified when this value changes.
Connection	connectNotify(Slot<? super T> slot) Connects the supplied listener to this value, such that it will be notified when this value changes.
Connection	connectNotify(ValueView.Listener<? super T> listener) Connects the supplied listener to this value, such that it will be notified when this value changes.
void	disconnect(ValueView.Listener<? super T> listener) Disconnects the supplied listener from this value if it's connected.
boolean	equals(Object other)
<M> ValueView<M>	flatMap(Function<? super T,? extends ValueView<M>> func) Creates a value that flat maps (monadic binds) this value via a function.
int	hashCode()
<M> ValueView<M>	map(Function<? super T,M> func) Creates a value that maps this value via a function.
String	toString()
RFuture<T>	when(Function<? super T,Boolean> cond) Returns a future which is completed with this value when the value meeds cond.

Methods inherited from class react.Reactor

clearConnections, hasConnections

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface react.ValueView

get

Constructor Detail

AbstractValue

public AbstractValue()

Method Detail

map

public <M> ValueView<M> map(Function<? super T,M> func)

Description copied from interface: ValueView

Creates a value that maps this value via a function. When this value changes, the mapped listeners will be notified, regardless of whether the new and old mapped values differ. The mapped value will retain a connection to this value for as long as it has connections of its own.

Specified by:

map in interface ValueView<T>

flatMap

public <M> ValueView<M> flatMap(Function<? super T,? extends ValueView<M>> func)

Description copied from interface: ValueView

Creates a value that flat maps (monadic binds) this value via a function. When this value changes, the mapping function is called to obtain a new reactive value. All of the listeners to the flat mapped value are "transferred" to the new reactive value. The mapped value will retain a connection to the most recent reactive value for as long as it has connections of its own.

Specified by:

flatMap in interface ValueView<T>

changes

public SignalView<T> changes()

Description copied from interface: ValueView

Returns a signal that is emitted whenever this value changes.

Specified by:

changes in interface ValueView<T>

when

public RFuture<T> when(Function<? super T,Boolean> cond)

Description copied from interface: ValueView

Returns a future which is completed with this value when the value meeds cond. If the value meets cond now, the future will be completed immediately, otherwise the future will be completed when the value changes to a value which meets cond.

Specified by:

when in interface ValueView<T>

connect

public Connection connect(ValueView.Listener<? super T> listener)

Description copied from interface: ValueView

Connects the supplied listener to this value, such that it will be notified when this value changes. The listener is held by a strong reference, so it's held in memory by virtue of being connected.

Specified by:

connect in interface ValueView<T>

Returns:

a connection instance which can be used to cancel the connection.

connectNotify

public Connection connectNotify(ValueView.Listener<? super T> listener)

Description copied from interface: ValueView

Connects the supplied listener to this value, such that it will be notified when this value changes. Also immediately notifies the listener of the current value. Note that the previous value supplied with this notification will be null. If the notification triggers an unchecked exception, the slot will automatically be disconnected and the caller need not worry about cleaning up after itself.

Specified by:

connectNotify in interface ValueView<T>

Returns:

a connection instance which can be used to cancel the connection.

connect

public Connection connect(SignalView.Listener<? super T> listener)

Description copied from interface: ValueView

Connects the supplied listener to this value, such that it will be notified when this value changes. The listener is held by a strong reference, so it's held in memory by virtue of being connected.

Specified by:

connect in interface ValueView<T>

Returns:

a connection instance which can be used to cancel the connection.

connectNotify

public Connection connectNotify(SignalView.Listener<? super T> listener)

Description copied from interface: ValueView

Connects the supplied listener to this value, such that it will be notified when this value changes. Also immediately notifies the listener of the current value. If the notification triggers an unchecked exception, the slot will automatically be disconnected and the caller need not worry about cleaning up after itself.

Specified by:

connectNotify in interface ValueView<T>

Returns:

a connection instance which can be used to cancel the connection.

connect

public Connection connect(Slot<? super T> slot)

Description copied from interface: ValueView

Connects the supplied listener to this value, such that it will be notified when this value changes. The listener is held by a strong reference, so it's held in memory by virtue of being connected.

Specified by:

connect in interface ValueView<T>

Returns:

a connection instance which can be used to cancel the connection.

connectNotify

public Connection connectNotify(Slot<? super T> slot)

Description copied from interface: ValueView

Connects the supplied listener to this value, such that it will be notified when this value changes. Also immediately notifies the listener of the current value. If the notification triggers an unchecked exception, the slot will automatically be disconnected and the caller need not worry about cleaning up after itself.

Specified by:

connectNotify in interface ValueView<T>

Returns:

a connection instance which can be used to cancel the connection.

disconnect

public void disconnect(ValueView.Listener<? super T> listener)

Description copied from interface: ValueView

Disconnects the supplied listener from this value if it's connected. If the listener has been connected multiple times, all connections are cancelled.

Specified by:

disconnect in interface ValueView<T>

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object other)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object