org.jboss.resteasy.rxjava2

Class ResteasyContextPropagatingOnObservableCreateAction

java.lang.Object

org.jboss.resteasy.rxjava2.ResteasyContextPropagatingOnObservableCreateAction

All Implemented Interfaces:

io.reactivex.functions.BiFunction<io.reactivex.Observable,io.reactivex.Observer,io.reactivex.Observer>

public class ResteasyContextPropagatingOnObservableCreateAction
extends Object
implements io.reactivex.functions.BiFunction<io.reactivex.Observable,io.reactivex.Observer,io.reactivex.Observer>

Constructor Summary

Constructors

Constructor and Description
ResteasyContextPropagatingOnObservableCreateAction()

Method Summary

Modifier and Type	Method and Description
io.reactivex.Observer	apply(io.reactivex.Observable t1, io.reactivex.Observer t2)

Methods inherited from class java.lang.Object

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

Constructor Detail

ResteasyContextPropagatingOnObservableCreateAction

public ResteasyContextPropagatingOnObservableCreateAction()

Method Detail

apply

public io.reactivex.Observer apply(io.reactivex.Observable t1,
                                   io.reactivex.Observer t2)
                            throws Exception

Specified by:

apply in interface io.reactivex.functions.BiFunction<io.reactivex.Observable,io.reactivex.Observer,io.reactivex.Observer>

Throws:

Exception