Package org.jsignal.rx

Class Effect

java.lang.Object

org.jsignal.rx.Effect

All Implemented Interfaces:

Runnable, Disposable, EffectLike, Idable

Direct Known Subclasses:

SideEffect

public class Effect
extends Object
implements EffectLike

Field Summary

Fields

Modifier and Type	Field	Description
protected final Cleanups	cleanups
static final Context<Optional<EffectLike>>	context
protected boolean	disposed
protected final Runnable	effect
protected final int	id
protected static final AtomicInteger	nextId
protected final Provider	provider
protected final LinkedHashSet<SignalLike<?>>	signals
protected final Thread	thread

Constructor Summary

Constructors

Constructor	Description
Effect(Runnable effect)

Method Summary

Modifier and Type	Method	Description
protected void	clear()
static Effect	create(Runnable runnable)
void	dispose()
boolean	equals(Object obj)
Cleanups	getCleanups()
int	getId()
Collection<SignalLike<?>>	getSignals()
Thread	getThread()
int	hashCode()
boolean	isDisposed()
static int	nextId()
void	onTrack(SignalLike<?> signal)	This method should only be called inside of implementations of Trackable.track()
void	onUntrack(SignalLike<?> signal)	This method should only be called inside of implementations of Trackable.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<EffectLike>> 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

signals

protected final LinkedHashSet<SignalLike<?>> signals

disposed

protected boolean disposed

Constructor Details

Effect

public Effect(Runnable effect)

Method Details

getThread

public Thread getThread()

Specified by:

getThread in interface EffectLike

onTrack

public void onTrack(SignalLike<?> signal)

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

Specified by:

onTrack in interface EffectLike

onUntrack

public void onUntrack(SignalLike<?> signal)

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

Specified by:

onUntrack in interface EffectLike

getId

public int getId()

Specified by:

getId in interface Idable

dispose

public void dispose()

Specified by:

dispose in interface Disposable

isDisposed

public boolean isDisposed()

Specified by:

isDisposed in interface Disposable

run

public void run()

Specified by:

run in interface Runnable

getSignals

public Collection<SignalLike<?>> getSignals()

Specified by:

getSignals in interface EffectLike

getCleanups

public Cleanups getCleanups()

Specified by:

getCleanups in interface EffectLike

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)