hu.akarnokd.reactive4java.util

Class Subjects

java.lang.Object

hu.akarnokd.reactive4java.util.Subjects

public final class Subjects
extends java.lang.Object

Utility class to wrap existing pairs of Observers and Observables under the Subject interface.

Since:

0.97

Method Summary

Modifier and Type	Method and Description
static <T> Subject<T,T>	newSubject() Creates a new subject which simply forwards its observed values to the registered observers.
static <T,U> Subject<T,U>	newSubject(Func1<? super T,? extends U> selector) Creates a new subject which forwards its observed values after applying the selector function.
static <T,U> Subject<T,U>	newSubject(Observer<? super T> observer, Observable<? extends U> observable) Wraps the observer and observable instances into a Subject.

Methods inherited from class java.lang.Object

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

Method Detail

newSubject

@Nonnull
public static <T,U> Subject<T,U> newSubject(@Nonnull
                                                      Observer<? super T> observer,
                                                      @Nonnull
                                                      Observable<? extends U> observable)

Wraps the observer and observable instances into a Subject.

Type Parameters:

T - the type the observer uses

U - the type the observable uses

Parameters:

observer - the observer object

observable - the observable object

Returns:

the subject relaying to both

newSubject

@Nonnull
public static <T> Subject<T,T> newSubject()

Creates a new subject which simply forwards its observed values to the registered observers.

Type Parameters:

T - the element type

Returns:

the new subject

newSubject

@Nonnull
public static <T,U> Subject<T,U> newSubject(@Nonnull
                                                      Func1<? super T,? extends U> selector)

Creates a new subject which forwards its observed values after applying the selector function.

Type Parameters:

T - the observed element type

U - the forwarded element type

Parameters:

selector - the selector to use

Returns:

the new subject