Uses of Interface
org.reactivestreams.Processor
-
Packages that use Processor Package Description org.reactivestreams org.reactivestreams.tck org.reactivestreams.tck.flow -
-
Uses of Processor in org.reactivestreams
Classes in org.reactivestreams that implement Processor Modifier and Type Class Description (package private) static class
FlowAdapters.ReactiveToFlowProcessor<T,U>
Wraps a Flow Processor and forwards methods of the Reactive Streams Processor to it.Fields in org.reactivestreams declared as Processor Modifier and Type Field Description (package private) Processor<? super T,? extends U>
FlowAdapters.FlowToReactiveProcessor. reactiveStreams
Methods in org.reactivestreams that return Processor Modifier and Type Method Description static <T,U>
Processor<T,U>FlowAdapters. toProcessor(java.util.concurrent.Flow.Processor<? super T,? extends U> flowProcessor)
Converts a Flow Processor into a Reactive Streams Processor.Methods in org.reactivestreams with parameters of type Processor Modifier and Type Method Description static <T,U>
java.util.concurrent.Flow.Processor<T,U>FlowAdapters. toFlowProcessor(Processor<? super T,? extends U> reactiveStreamsProcessor)
Converts a Reactive Streams Processor into a Flow Processor.Constructors in org.reactivestreams with parameters of type Processor Constructor Description FlowToReactiveProcessor(Processor<? super T,? extends U> reactive)
-
Uses of Processor in org.reactivestreams.tck
Fields in org.reactivestreams.tck declared as Processor Modifier and Type Field Description (package private) Processor<T,T>
IdentityProcessorVerification.TestSetup. processor
Methods in org.reactivestreams.tck that return Processor Modifier and Type Method Description abstract Processor<T,T>
IdentityProcessorVerification. createIdentityProcessor(int bufferSize)
This is the main method you must implement in your test incarnation. -
Uses of Processor in org.reactivestreams.tck.flow
Methods in org.reactivestreams.tck.flow that return Processor Modifier and Type Method Description Processor<T,T>
IdentityFlowProcessorVerification. createIdentityProcessor(int bufferSize)
-