Package io.github.zero88.schedulerx.rxjava3

Interface Rx3MaybeJob<INPUT,OUTPUT>

All Superinterfaces:

AsyncJob<INPUT,OUTPUT>, FuturableJob<INPUT,OUTPUT,io.reactivex.rxjava3.core.Maybe<OUTPUT>,ExecutionContext<OUTPUT>>, Job<INPUT,OUTPUT>

public interface Rx3MaybeJob<INPUT,OUTPUT>

Job interface for Maybe in #reactivex version.

Since:

2.0.0

Method Summary

Modifier and Type	Method	Description
io.reactivex.rxjava3.core.Maybe<OUTPUT>	doExecute(@NotNull JobData<INPUT> jobData, ExecutionContext<OUTPUT> executionContext)	Async execute
default ExecutionContext<OUTPUT>	transformContext(ExecutionContext<OUTPUT> executionContext)	Transform execution context to Rxified execution context
default io.vertx.core.Future<OUTPUT>	transformResult(io.reactivex.rxjava3.core.Maybe<OUTPUT> result)	Transform the Rxified execution result to Vert.x Future version

Methods inherited from interface io.github.zero88.schedulerx.AsyncJob

execute

Methods inherited from interface io.github.zero88.schedulerx.FuturableJob

asyncExecute

Method Details

transformResult

default io.vertx.core.Future<OUTPUT> transformResult(io.reactivex.rxjava3.core.Maybe<OUTPUT> result)

Description copied from interface: FuturableJob

Transform the Rxified execution result to Vert.x Future version

Specified by:

transformResult in interface FuturableJob<INPUT,OUTPUT,io.reactivex.rxjava3.core.Maybe<OUTPUT>,ExecutionContext<OUTPUT>>

Parameters:

result - Rxified execution result

Returns:

the execution result in Future

doExecute

io.reactivex.rxjava3.core.Maybe<OUTPUT> doExecute(@NotNull
 @NotNull JobData<INPUT> jobData,
 @NotNull
 ExecutionContext<OUTPUT> executionContext)

Description copied from interface: FuturableJob

Async execute

Specified by:

doExecute in interface FuturableJob<INPUT,OUTPUT,io.reactivex.rxjava3.core.Maybe<OUTPUT>,ExecutionContext<OUTPUT>>

Parameters:

jobData - job data

executionContext - job execution context

Returns:

the Rxified execution result

transformContext

default ExecutionContext<OUTPUT> transformContext(@NotNull
 ExecutionContext<OUTPUT> executionContext)

Description copied from interface: FuturableJob

Transform execution context to Rxified execution context

Specified by:

transformContext in interface FuturableJob<INPUT,OUTPUT,T,ExecutionContext<OUTPUT>>

Parameters:

executionContext - job execution context

Returns:

Rxified execution context

See Also:

• ExecutionContext