com.aol.cyclops.reactor.types

Interface ReactorConvertable<T>

Type Parameters:

T - type of elements contained

All Known Implementing Classes:

AbstractFluentCollectionX, LazyDequeX, LazyListX, LazyPBagX, LazyPOrderedSetX, LazyPQueueX, LazyPSetX, LazyPStackX, LazyPVectorX, LazyQueueX, LazySetX, LazySortedSetX

public interface ReactorConvertable<T>

Represents a type that can be converted to a Reactor Flux or Mono

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Flux<T>	flux() Convert this type to a Reactor Flux
default reactor.core.publisher.Mono<T>	mono() Convert this type to a Reactor Mono

Method Detail

flux

reactor.core.publisher.Flux<T> flux()

Convert this type to a Reactor Flux

Returns:

Reactor Flux

mono

default reactor.core.publisher.Mono<T> mono()

Convert this type to a Reactor Mono

Returns:

Reactor Mono