hu.akarnokd.reactive4java.swing

Class SwingObservables

java.lang.Object

hu.akarnokd.reactive4java.swing.SwingObservables

public final class SwingObservables
extends java.lang.Object

Utility class to wrap typical Swing events into observables.

Method Summary

Modifier and Type	Method and Description
static <T> T	create(java.lang.Class<T> listener, Observer<? super Dynamic> bindTo) Create a dynamic observer for the given listener interface by proxying all method calls.
static Scheduler	getDefaultEdtScheduler()
static <T> Observable<T>	observeOnEdt(Observable<T> observable) Wrap the observable to the Event Dispatch Thread for listening to events.
static Scheduler	replaceDefaultEdtScheduler(Scheduler newScheduler) Replace the current default scheduler with the specified new scheduler.
static void	restoreDefaultEdtScheduler() Restore the default scheduler back to the DefaultScheduler used when this class was initialized.
static <T> Observable<T>	subscribeOnEdt(Observable<T> observable) Wrap the observable to the Event Dispatch Thread for subscribing to events.

Methods inherited from class java.lang.Object

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

Method Detail

create

@Nonnull
public static <T> T create(@Nonnull
                                     java.lang.Class<T> listener,
                                     @Nonnull
                                     Observer<? super Dynamic> bindTo)

Create a dynamic observer for the given listener interface by proxying all method calls. None of the methods of the listener interface should require something meaningful to be returned, i.e., they all must be void, return Void (or the original call site should accept nulls). Note that due this proxying effect, the handler invocation may be 100 times slower than a direct implementation

Type Parameters:

T - the listener interface type

Parameters:

listener - the list interface class

bindTo - the target observer, use the DefaultObservable

Returns:

the proxy instance

observeOnEdt

@Nonnull
public static <T> Observable<T> observeOnEdt(@Nonnull
                                                       Observable<T> observable)

Wrap the observable to the Event Dispatch Thread for listening to events.

Type Parameters:

T - the value type to observe

Parameters:

observable - the original observable

Returns:

the new observable

getDefaultEdtScheduler

@Nonnull
public static Scheduler getDefaultEdtScheduler()

Returns:

the current default pool used by the Observables methods

replaceDefaultEdtScheduler

@Nonnull
public static Scheduler replaceDefaultEdtScheduler(@Nonnull
                                                             Scheduler newScheduler)

Replace the current default scheduler with the specified new scheduler. This method is threadsafe

Parameters:

newScheduler - the new scheduler

Returns:

the current scheduler

restoreDefaultEdtScheduler

public static void restoreDefaultEdtScheduler()

Restore the default scheduler back to the DefaultScheduler used when this class was initialized.

subscribeOnEdt

@Nonnull
public static <T> Observable<T> subscribeOnEdt(Observable<T> observable)

Wrap the observable to the Event Dispatch Thread for subscribing to events.

Type Parameters:

T - the value type to observe

Parameters:

observable - the original observable

Returns:

the new observable