Publishers (micronaut 3.4.0 API)

java.lang.Object
- io.micronaut.core.async.publisher.Publishers

```
@Internal
public class Publishers
extends Object
```
Utilities for working with raw Publisher instances. Designed for internal use by Micronaut and not as a replacement for a reactive library such as RxJava, Reactor, Akka etc.

Since:

1.0

Author:

Graeme Rocher

Nested Class Summary

Nested Classes
Modifier and Type	Class and Description
`static class`	`Publishers.JustPublisher<T>` A publisher for a value.
`static interface`	`Publishers.MapOrSupplyEmpty<T,R>` Maps the next result or supplies an empty result.
`static interface`	`Publishers.MicronautPublisher<T>` Marker interface for any micronaut produced publishers.

Constructor Summary

Constructors
Constructor and Description

Publishers()

Constructors
Constructor and Description
`Publishers()`

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method and Description
`static <T> T`	`convertPublisher(Object object, Class<T> publisherType)` Attempts to convert the publisher to the given type.
`static <T> Publisher<T>`	`empty()` A `Publisher` that completes without emitting any items.
`static <T> Publisher<T>`	`fromCompletableFuture(CompletableFuture<T> future)` Build a `Publisher` from a `CompletableFuture`.
`static <T> Publisher<T>`	`fromCompletableFuture(Supplier<CompletableFuture<T>> futureSupplier)` Build a `Publisher` from a `CompletableFuture`.
`static List<Class<?>>`	`getKnownCompletableTypes()`
`static List<Class<?>>`	`getKnownReactiveTypes()`
`static List<Class<?>>`	`getKnownSingleTypes()`
`static boolean`	`isCompletable(Class<?> type)` Does the given reactive type emit a single result.
`static boolean`	`isConvertibleToPublisher(Class<?> type)` Is the given type a Publisher or convertible to a publisher.
`static boolean`	`isConvertibleToPublisher(Object object)` Is the given object a Publisher or convertible to a publisher.
`static boolean`	`isSingle(Class<?> type)` Does the given reactive type emit a single result.
`static <T> Publisher<T>`	`just(T value)` A `Publisher` that emits a fixed single value.
`static <T> Publisher<T>`	`just(Throwable error)` A `Publisher` that emits a fixed single value.
`static <T,R> Publisher<R>`	`map(Publisher<T> publisher, Function<T,R> mapper)` Map the result from a publisher using the given mapper.
`static <T,R> Publisher<R>`	`mapOrSupplyEmpty(Publisher<T> publisher, Publishers.MapOrSupplyEmpty<T,R> mapOrSupplyEmpty)` Map the result from a publisher using the given mapper or supply empty value.
`static <T> Publisher<T>`	`onComplete(Publisher<T> publisher, Supplier<CompletableFuture<Void>> future)` Allow executing logic on completion of a Publisher.
`static void`	`registerReactiveCompletable(Class<?> type)` Registers an additional reactive completable type.
`static void`	`registerReactiveSingle(Class<?> type)` Registers an additional reactive single type.
`static void`	`registerReactiveType(Class<?> type)` Registers an additional reactive type.
`static <T> Publisher<T>`	`then(Publisher<T> publisher, Consumer<T> consumer)` Map the result from a publisher using the given mapper.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - Publishers
```
public Publishers()
```
- Method Detail
  - registerReactiveType
```
public static void registerReactiveType(Class<?> type)
```
    Registers an additional reactive type. Should be called during application static initialization.
    
    Parameters:
    
    type - The type
    
    Since:
    
    2.0
  - registerReactiveSingle
```
public static void registerReactiveSingle(Class<?> type)
```
    Registers an additional reactive single type. Should be called during application static initialization.
    
    Parameters:
    
    type - The type
    
    Since:
    
    2.0
  - registerReactiveCompletable
```
public static void registerReactiveCompletable(Class<?> type)
```
    Registers an additional reactive completable type. Should be called during application static initialization.
    
    Parameters:
    
    type - The type
    
    Since:
    
    2.0
  - getKnownReactiveTypes
```
public static List<Class<?>> getKnownReactiveTypes()
```
    Returns:
    
    A list of known reactive types.
  - getKnownSingleTypes
```
public static List<Class<?>> getKnownSingleTypes()
```
    Returns:
    
    A list of known single types.
  - getKnownCompletableTypes
```
public static List<Class<?>> getKnownCompletableTypes()
```
    Returns:
    
    A list of known single types.
  - fromCompletableFuture
```
public static <T> Publisher<T> fromCompletableFuture(Supplier<CompletableFuture<T>> futureSupplier)
```
    Build a Publisher from a CompletableFuture.
    
    Type Parameters:
    
    T - The type of the publisher
    
    Parameters:
    
    futureSupplier - The supplier of the CompletableFuture
    
    Returns:
    
    The Publisher
  - fromCompletableFuture
```
public static <T> Publisher<T> fromCompletableFuture(CompletableFuture<T> future)
```
    Build a Publisher from a CompletableFuture.
    
    Type Parameters:
    
    T - The type of the publisher
    
    Parameters:
    
    future - The CompletableFuture
    
    Returns:
    
    The Publisher
  - just
```
public static <T> Publisher<T> just(T value)
```
    A Publisher that emits a fixed single value.
    
    Type Parameters:
    
    T - The value type
    
    Parameters:
    
    value - The value to emit
    
    Returns:
    
    The Publisher
  - just
```
public static <T> Publisher<T> just(Throwable error)
```
    A Publisher that emits a fixed single value.
    
    Type Parameters:
    
    T - The value type
    
    Parameters:
    
    error - The error to emit
    
    Returns:
    
    The Publisher
  - empty
```
public static <T> Publisher<T> empty()
```
    A Publisher that completes without emitting any items.
    
    Type Parameters:
    
    T - The value type
    
    Returns:
    
    The Publisher
    
    Since:
    
    2.0.0
  - map
```
public static <T,R> Publisher<R> map(Publisher<T> publisher,
                                     Function<T,R> mapper)
```
    Map the result from a publisher using the given mapper.
    
    Type Parameters:
    
    T - The generic type
    
    R - The result type
    
    Parameters:
    
    publisher - The publisher
    
    mapper - The mapper
    
    Returns:
    
    The mapped publisher
  - mapOrSupplyEmpty
```
public static <T,R> Publisher<R> mapOrSupplyEmpty(Publisher<T> publisher,
                                                  Publishers.MapOrSupplyEmpty<T,R> mapOrSupplyEmpty)
```
    Map the result from a publisher using the given mapper or supply empty value.
    
    Type Parameters:
    
    T - The generic type
    
    R - The result type
    
    Parameters:
    
    publisher - The publisher
    
    mapOrSupplyEmpty - The mapOrSupplyEmpty
    
    Returns:
    
    The mapped publisher
    
    Since:
    
    2.5.0
  - then
```
public static <T> Publisher<T> then(Publisher<T> publisher,
                                    Consumer<T> consumer)
```
    Map the result from a publisher using the given mapper.
    
    Type Parameters:
    
    T - The generic type
    
    Parameters:
    
    publisher - The publisher
    
    consumer - The mapper
    
    Returns:
    
    The mapped publisher
  - onComplete
```
public static <T> Publisher<T> onComplete(Publisher<T> publisher,
                                          Supplier<CompletableFuture<Void>> future)
```
    Allow executing logic on completion of a Publisher.
    
    Type Parameters:
    
    T - The generic type
    
    Parameters:
    
    publisher - The publisher
    
    future - The runnable
    
    Returns:
    
    The mapped publisher
  - isConvertibleToPublisher
```
public static boolean isConvertibleToPublisher(Class<?> type)
```
    Is the given type a Publisher or convertible to a publisher.
    
    Parameters:
    
    type - The type to check
    
    Returns:
    
    True if it is
  - isConvertibleToPublisher
```
public static boolean isConvertibleToPublisher(Object object)
```
    Is the given object a Publisher or convertible to a publisher.
    
    Parameters:
    
    object - The object
    
    Returns:
    
    True if it is
  - convertPublisher
```
public static <T> T convertPublisher(Object object,
                                     Class<T> publisherType)
```
    Attempts to convert the publisher to the given type.
    
    Type Parameters:
    
    T - The generic type
    
    Parameters:
    
    object - The object to convert
    
    publisherType - The publisher type
    
    Returns:
    
    The Resulting in publisher
  - isSingle
```
public static boolean isSingle(Class<?> type)
```
    Does the given reactive type emit a single result.
    
    Parameters:
    
    type - The type
    
    Returns:
    
    True it does
  - isCompletable
```
public static boolean isCompletable(Class<?> type)
```
    Does the given reactive type emit a single result.
    
    Parameters:
    
    type - The type
    
    Returns:
    
    True it does

Class Publishers

Nested Class Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

Publishers

Method Detail

registerReactiveType

registerReactiveSingle

registerReactiveCompletable

getKnownReactiveTypes

getKnownSingleTypes

getKnownCompletableTypes

fromCompletableFuture

fromCompletableFuture

just

just

empty

map

mapOrSupplyEmpty

then

onComplete

isConvertibleToPublisher

isConvertibleToPublisher

convertPublisher

isSingle

isCompletable