Module io.smallrye.mutiny.zero

Package mutiny.zero.operators

Class Spread<T,R>

java.lang.Object

mutiny.zero.operators.Spread<T,R>

Type Parameters:

T - the upstream item type

R - the downstream (flattened) item type

All Implemented Interfaces:

Flow.Publisher<R>

public class Spread<T,R>
extends Object
implements Flow.Publisher<R>

A Flow.Publisher that maps each upstream item to a Flow.Publisher and flattens the results with bounded concurrency.

With concurrency = 1 this behaves as a concatMap (strict ordering). With concurrency > 1 items from different inner publishers may interleave.

Constructor Summary

Constructors

Constructor	Description
Spread(Flow.Publisher<T> upstream, Function<T,@Nullable Flow.Publisher<R>> mapper, int concurrency, int prefetch)	Create a new spread (flatMap) publisher.

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

Spread

public Spread(Flow.Publisher<T> upstream,
 Function<T,@Nullable Flow.Publisher<R>> mapper,
 int concurrency,
 int prefetch)

Create a new spread (flatMap) publisher.

Parameters:

upstream - the upstream publisher, must not be null

mapper - the mapping function, must not be null

concurrency - the maximum number of concurrent inner subscriptions, must be positive

prefetch - the per-inner request batch size, must be positive

Method Details

subscribe

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

Specified by:

subscribe in interface Flow.Publisher<T>