com.github.davidmoten.rx.internal.operators

Class OperatorFromTransformer<R,T>

java.lang.Object

com.github.davidmoten.rx.internal.operators.OperatorFromTransformer<R,T>

Type Parameters:

R - to type

T - from type

All Implemented Interfaces:

rx.functions.Func1<rx.Subscriber<? super R>,rx.Subscriber<? super T>>, rx.functions.Function, rx.Observable.Operator<R,T>

public final class OperatorFromTransformer<R,T>
extends Object
implements rx.Observable.Operator<R,T>

Converts an Transformer (a function converting one Observable into another) into an Observable.Operator.

Constructor Summary

Constructors

Constructor and Description
OperatorFromTransformer(rx.functions.Func1<? super rx.Observable<T>,? extends rx.Observable<R>> operation) Constructor.

Method Summary

Modifier and Type	Method and Description
rx.Subscriber<? super T>	call(rx.Subscriber<? super R> subscriber)
static <R,T> rx.Observable.Operator<R,T>	toOperator(rx.functions.Func1<? super rx.Observable<T>,? extends rx.Observable<R>> operation)

Methods inherited from class java.lang.Object

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

Constructor Detail

OperatorFromTransformer

public OperatorFromTransformer(rx.functions.Func1<? super rx.Observable<T>,? extends rx.Observable<R>> operation)

Constructor.

Parameters:

operation - to be converted into Observable.Operator

Method Detail

toOperator

public static <R,T> rx.Observable.Operator<R,T> toOperator(rx.functions.Func1<? super rx.Observable<T>,? extends rx.Observable<R>> operation)

call

public rx.Subscriber<? super T> call(rx.Subscriber<? super R> subscriber)

Specified by:

call in interface rx.functions.Func1<rx.Subscriber<? super R>,rx.Subscriber<? super T>>