io.apptik.roxy

Class ReactorProcProxy

java.lang.Object

io.apptik.roxy.RSProcProxy<reactor.core.publisher.Flux>

io.apptik.roxy.ReactorProcProxy

All Implemented Interfaces:

io.apptik.roxy.Roxy<reactor.core.publisher.Flux>

public class ReactorProcProxy
extends io.apptik.roxy.RSProcProxy<reactor.core.publisher.Flux>

Roxy implementation using Reactor-Core

Nested Class Summary

Nested classes/interfaces inherited from interface io.apptik.roxy.Roxy

io.apptik.roxy.Roxy.Event, io.apptik.roxy.Roxy.TePolicy

Constructor Summary

Constructors

Constructor and Description
ReactorProcProxy(reactor.core.publisher.FluxProcessor proc, io.apptik.roxy.Roxy.TePolicy tePolicy)

Method Summary

Modifier and Type	Method and Description
protected <T> reactor.core.publisher.Flux<T>	filter(org.reactivestreams.Processor processor, java.lang.Class<T> filterClass)
protected reactor.core.publisher.Flux	hide(org.reactivestreams.Processor processor)

Methods inherited from class io.apptik.roxy.RSProcProxy

addUpstream, clear, complete, emit, pub, pub, removeUpstream, tePolicy

Methods inherited from class java.lang.Object

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

Constructor Detail

ReactorProcProxy

public ReactorProcProxy(reactor.core.publisher.FluxProcessor proc,
                        io.apptik.roxy.Roxy.TePolicy tePolicy)

Method Detail

hide

protected reactor.core.publisher.Flux hide(org.reactivestreams.Processor processor)

Specified by:

hide in class io.apptik.roxy.RSProcProxy<reactor.core.publisher.Flux>

filter

protected <T> reactor.core.publisher.Flux<T> filter(org.reactivestreams.Processor processor,
                                                    java.lang.Class<T> filterClass)

Specified by:

filter in class io.apptik.roxy.RSProcProxy<reactor.core.publisher.Flux>