io.smallrye.reactive.streams.vertx

Class VertxExecutionModel

java.lang.Object

io.smallrye.reactive.streams.vertx.VertxExecutionModel

All Implemented Interfaces:

ExecutionModel, Function<io.reactivex.Flowable,io.reactivex.Flowable>, UnaryOperator<io.reactivex.Flowable>

public class VertxExecutionModel
extends Object
implements ExecutionModel

An implementation of ExecutionModel enforcing the Vert.x execution model.

Constructor Summary

Constructors

Constructor and Description
VertxExecutionModel()

Method Summary

Modifier and Type	Method and Description
io.reactivex.Flowable	apply(io.reactivex.Flowable input)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.UnaryOperator

identity

Methods inherited from interface java.util.function.Function

andThen, compose

Constructor Detail

VertxExecutionModel

public VertxExecutionModel()

Method Detail

apply

public io.reactivex.Flowable apply(io.reactivex.Flowable input)

Specified by:

apply in interface Function<io.reactivex.Flowable,io.reactivex.Flowable>