Package org.jsignal.rx

Class Effect

java.lang.Object

org.jsignal.rx.Effect

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

SideEffect

public class Effect
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field	Description
protected final Cleanups	cleanups
static final Context<Optional<Effect>>	context
protected boolean	disposed
protected final Runnable	effect
protected final int	id
protected final LinkedHashSet<Signal<?>>	inbound
protected static final AtomicInteger	nextId
protected final Set<Signal<?>>	outbound
protected final Provider	provider
protected final Thread	thread

Constructor Summary

Constructors

Constructor	Description
Effect(Runnable effect, Set<Signal<?>> outbound)

Method Summary

Modifier and Type	Method	Description
protected void	clear()
static Effect	create(Runnable runnable)
static Effect	create(Runnable runnable, Set<Signal<?>> outbound)
void	dispose()
boolean	equals(Object obj)
Cleanups	getCleanups()
int	getId()
Collection<Signal<?>>	getInbound()
Collection<Signal<?>>	getOutbound()
Thread	getThread()
int	hashCode()
boolean	isDisposed()
static int	nextId()
void	onTrack(Signal<?> signal)	This method should only be called inside of implementations of Signal.track()
void	onUntrack(Signal<?> signal)	This method should only be called inside of implementations of Signal.untrack()
void	run()
protected void	run(Runnable inner)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Field Details

context

public static final Context<Optional<Effect>> context

nextId

protected static final AtomicInteger nextId

thread

protected final Thread thread

id

protected final int id

effect

protected final Runnable effect

cleanups

protected final Cleanups cleanups

provider

protected final Provider provider

inbound

protected final LinkedHashSet<Signal<?>> inbound

outbound

protected final Set<Signal<?>> outbound

disposed

protected boolean disposed

Constructor Details

Effect

public Effect(Runnable effect,
 Set<Signal<?>> outbound)

Method Details

getThread

public Thread getThread()

onTrack

public void onTrack(Signal<?> signal)

This method should only be called inside of implementations of Signal.track()

onUntrack

public void onUntrack(Signal<?> signal)

This method should only be called inside of implementations of Signal.untrack()

getId

public int getId()

dispose

public void dispose()

isDisposed

public boolean isDisposed()

run

public void run()

Specified by:

run in interface Runnable

getInbound

public Collection<Signal<?>> getInbound()

getOutbound

public Collection<Signal<?>> getOutbound()

getCleanups

public Cleanups getCleanups()

run

protected void run(Runnable inner)

clear

protected void clear()

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

nextId

public static int nextId()

create

public static Effect create(Runnable runnable)

create

public static Effect create(Runnable runnable,
 Set<Signal<?>> outbound)