Package org.infinispan.reactive.publisher

Class PublisherTransformers

java.lang.Object

org.infinispan.reactive.publisher.PublisherTransformers

public class PublisherTransformers
extends Object

Static factory method class to provide various transformers for use with distributed Publisher. Note that these functions are all serializable by Infinispan assuming that any passed arguments are as well.

Since:

11.0

Author:

wburns

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	PublisherTransformers.PublisherTransformersExternalizer

Method Summary

Modifier and Type	Method	Description
static <I> Function<org.reactivestreams.Publisher<I>,org.reactivestreams.Publisher<I>>	identity()

Methods inherited from class java.lang.Object

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

Method Details

identity

public static <I>
Function<org.reactivestreams.Publisher<I>,org.reactivestreams.Publisher<I>> identity()