Module mutiny.zero

Package mutiny.zero.operators

Class Transform<I,O>

java.lang.Object

mutiny.zero.operators.Transform<I,O>

Type Parameters:

I - the input elements type

O - the output elements type

All Implemented Interfaces:

Flow.Publisher<O>

public class Transform<I,O>
extends Object
implements Flow.Publisher<O>

A Flow.Publisher that transforms elements using a Function.

Constructor Summary

Constructors

Constructor	Description
Transform(Flow.Publisher<I> upstream, Function<I,O> function)	Build a new transformation publisher.

Method Summary

Modifier and Type	Method	Description
void	subscribe(Flow.Subscriber<? super O> subscriber)

Methods inherited from class java.lang.Object

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

Constructor Details

Transform

public Transform(Flow.Publisher<I> upstream,
 Function<I,O> function)

Build a new transformation publisher.

Parameters:

upstream - the upstream publisher

function - the transformation function, must not throw exceptions, must not return null values

Method Details

subscribe

public void subscribe(Flow.Subscriber<? super O> subscriber)

Specified by:

subscribe in interface Flow.Publisher<I>