Top Description Fields Constructors Methods
org.eclipse.jetty.reactive.client.internal

public Class Transformer<I, O>

extends AbstractSingleProcessor<I, O>
Class Inheritance
Type Parameters
<I>
the input type
<O>
the output type
Imports
java.util.Objects, java.util.function.Function

A org.reactivestreams.Processor that applies a function to transform items from input type I to output type O.

Field Summary

Modifier and TypeField and Description
private final Function<I, O>
transformer

Constructor Summary

AccessConstructor and Description
public
Transformer(Function<I, O> transformer)

Method Summary

Modifier and TypeMethod and Description
public void
onNext(I
the element signaled
i)

Implements org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).
Inherited from org.eclipse.jetty.reactive.client.internal.AbstractSingleProcessor:
canceldownStreamdownStreamOnNextonCompleteonErroronFailureonRequestonSubscribetoStringupStreamCancelupStreamRequest

Field Detail

transformerback to summary
private final Function<I, O> transformer

Constructor Detail

Transformerback to summary
public Transformer(Function<I, O> transformer)

Method Detail

onNextback to summary
public void onNext(I i)

Implements org.reactivestreams.Subscriber.onNext.

Doc from org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).

Parameters
i:I

the element signaled

Annotations
@Override