io.smallrye.reactive.converters.rxjava1

Class CompletableConverter

java.lang.Object

io.smallrye.reactive.converters.rxjava1.CompletableConverter

All Implemented Interfaces:

ReactiveTypeConverter<rx.Completable>

public class CompletableConverter
extends Object
implements ReactiveTypeConverter<rx.Completable>

Converter handling the RX Java 1 Completable type. toCompletionStage
The toCompletionStage(Completable) method returns a CompletionStage instance completed with an null value upon success or failed according to the Completable signals. fromCompletionStage
The fromCompletionStage(CompletionStage) method returns a Completable instance completed or failed according to the passed CompletionStage completion. If the future emits a null value, the Completable is completed successfully. If the future redeems a non-null value, the Completable completes successfully, but the value is ignored. If the future is completed with an exception, the Completable fails. fromPublisher
The fromPublisher(Publisher) method returns a Completable emitting the completion signal when the passed stream reached its end. If the passed Publisher is empty, the returned Completable completes. If the passed stream emits values, they are discarded. If the passed @{link Publisher} emits a failure before its completion, the returned Completable fails. toRSPublisher
The toRSPublisher(Completable) method returns a stream emitting an empty stream or a failed stream depending of the Completable.

Constructor Summary

Constructors

Constructor and Description
CompletableConverter()

Method Summary

Modifier and Type	Method and Description
boolean	emitAtMostOneItem()
boolean	emitItems()
rx.Completable	fromCompletionStage(CompletionStage cs) Transforms an instance of CompletionStage to an instance of T.
<X> rx.Completable	fromPublisher(org.reactivestreams.Publisher<X> publisher) Transforms an instance of T to a Publisher.
boolean	supportNullValue()
CompletionStage<Void>	toCompletionStage(rx.Completable instance) Transforms an instance of T to a CompletionStage completed with a potential value.
<X> org.reactivestreams.Publisher<X>	toRSPublisher(rx.Completable instance) Transforms an instance of T to a Publisher.
Class<rx.Completable>	type()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.smallrye.reactive.converters.ReactiveTypeConverter

requireAtLeastOneItem

Constructor Detail

CompletableConverter

public CompletableConverter()

Method Detail

toCompletionStage

public CompletionStage<Void> toCompletionStage(rx.Completable instance)

Description copied from interface: ReactiveTypeConverter

Transforms an instance of T to a CompletionStage completed with a potential value. Each converter instances can use specific rules, however the following set of rules are mandatory:

• The returned CompletionStage must never be null.
• The returned CompletionStage completes with the first emitted value. This value may be null for empty stream or instance of T emitting null as first value.
• If the passed instance emits several values, only the first one is considered, others are discarded.
• If the passed instance fails before emitting a value, the returned CompletionStage completes with this failure.
• If the passed instance does not emit any value and does not fail or complete, the returned CompletionStage does not complete.
• If the passed instance completes before
  emitting a value, the CompletionStage is completed with a null value.
• If the passed instance emits null as first value (if supported), the CompletionStage is completed with null. As a consequence, there are no differences between an instance emitting null as first value or completing without emitting a value. If the instance does not support emitting null values, the returned CompletionStage must be completed with a failure.

Specified by:

toCompletionStage in interface ReactiveTypeConverter<rx.Completable>

Parameters:

instance - the instance to convert to a CompletionStage. Must not be null.

Returns:

a non-null CompletionStage.

fromCompletionStage

public rx.Completable fromCompletionStage(CompletionStage cs)

Description copied from interface: ReactiveTypeConverter

Transforms an instance of CompletionStage to an instance of T. The value emitted by T depends on the completion of the passed CompletionStage. Each converter instances can use specific rules, however the following set of rules are mandatory:

• The returned T must never be null.
• If the passed CompletionStage never completes, no values are emitted by the returned T.
• If the passed CompletionStage redeems a null value, and if T support null values, null is emitted by the returned instance of T.
• If the passed CompletionStage redeems a null value, and if T does not support null values, a failure is emitted by the returned instance of T.
• If the passed CompletionStage redeems a non-null value, the value is emitted by the returned instance of T.
• If the passed CompletionStage is completed with a failure, the same failure is emitted by the returned instance of T.
• If the passed CompletionStage is cancelled before having completed, the CancellationException must be emitted by the returned instance.

Implementations must not expect the CompletionStage to be instances of CompletableFuture.

Implementations may decide to adapt the emitted result when receiving container object such as Optional.

Specified by:

fromCompletionStage in interface ReactiveTypeConverter<rx.Completable>

Parameters:

cs - the instance of CompletionStage, must not be null

Returns:

the instance of T, generally emitting instances of X.

toRSPublisher

public <X> org.reactivestreams.Publisher<X> toRSPublisher(rx.Completable instance)

Description copied from interface: ReactiveTypeConverter

Transforms an instance of T to a Publisher. Each converter instances can use specific rules, however the following set of rules are mandatory:

• The returned Publisher must never be null.
• All values emitted by the instance are emitted by the returned Publisher.
• If the instance emits a failure, Publisher propagates the same failure and terminates.
• If the instance completes, Publisher also completes.
• If the passed instance does not emit any value and does not fail or complete, the returned Publisher does not send any signals or values.
• If the passed instance completes before
  emitting a value, the Publisher also completes empty.
• If the passed instance emits null, the Publisher must send a failure (NullPointerException.
• If the instance support back-pressure, the resulting Publisher must enforce back-pressure. When the instance does not support back-pressure, the Publisher consumes the data without back-pressure using an unbounded-buffer. In other words, this operation is a pass-through for back-pressure and its behavior is determined by the back-pressure behavior of the passed instance.

Specified by:

toRSPublisher in interface ReactiveTypeConverter<rx.Completable>

Type Parameters:

X - the type emitted by the returned Publisher. It is generally the type of data emitted by the passed instance.

Parameters:

instance - the instance to convert to a Publisher. Must not be null.

Returns:

a non-null Publisher.

fromPublisher

public <X> rx.Completable fromPublisher(org.reactivestreams.Publisher<X> publisher)

Description copied from interface: ReactiveTypeConverter

Transforms an instance of T to a Publisher. Each converter instances can use specific rules, however the following set of rules are mandatory:

• The returned Publisher must never be null.
• If the instance of T emits a single value, the returned Publisher emits the same value and completes.
• If the instance of T does not emits value, sends the completion signal, the returned Publisher completes.
• If the instance of T emits a failure, the returned Publisher emits a failure.
• If the instance of T emits a null value, the returned Publisher emits an NullPointerException as null is not a valid value.
• If the instance of T does neither emits a value nor a signal, the returned Publisher does not emits values or signals.
• This operation is a pass-through for back-pressure and its behavior is determined by the back-pressure behavior of the returned instance.

Specified by:

fromPublisher in interface ReactiveTypeConverter<rx.Completable>

Type Parameters:

X - the type of data emitted by the passed Publisher.

Parameters:

publisher - the Publisher to convert. Must not be null.

Returns:

a non-null instance of T.

type

public Class<rx.Completable> type()

Specified by:

type in interface ReactiveTypeConverter<rx.Completable>

Returns:

the conversion type. Must not be null. Notice that sub-classes of the returned class are also managed by the same converter.

emitItems

public boolean emitItems()

Specified by:

emitItems in interface ReactiveTypeConverter<rx.Completable>

Returns:

true if the type T may emit items, false otherwise.

emitAtMostOneItem

public boolean emitAtMostOneItem()

Specified by:

emitAtMostOneItem in interface ReactiveTypeConverter<rx.Completable>

Returns:

true if the type T may emit items at most one item, false otherwise. Returning false to this method means that the converted type only signals about completion or error. Returning true means that ReactiveTypeConverter.emitItems() must also return true.

supportNullValue

public boolean supportNullValue()

Specified by:

supportNullValue in interface ReactiveTypeConverter<rx.Completable>

Returns:

true if the type T can emit or receive null as item.