io.reactivex.parallel

Interface ParallelTransformer<Upstream,Downstream>

Type Parameters:

Upstream - the upstream value type

Downstream - the downstream value type

public interface ParallelTransformer<Upstream,Downstream>

Interface to compose ParallelFlowable.

History: 2.0.8 - experimental

Since:

2.2

Method Summary

Modifier and Type	Method and Description
ParallelFlowable<Downstream>	apply(ParallelFlowable<Upstream> upstream) Applies a function to the upstream ParallelFlowable and returns a ParallelFlowable with optionally different element type.

Method Detail

apply

@NonNull
ParallelFlowable<Downstream> apply(@NonNull
                                            ParallelFlowable<Upstream> upstream)

Applies a function to the upstream ParallelFlowable and returns a ParallelFlowable with optionally different element type.

Parameters:

upstream - the upstream ParallelFlowable instance

Returns:

the transformed ParallelFlowable instance