Class PublisherBean
- java.lang.Object
-
- org.eclipse.microprofile.reactive.messaging.tck.signatures.publishers.PublisherBean
-
@ApplicationScoped public class PublisherBean extends Object
-
-
Constructor Summary
Constructors Constructor Description PublisherBean()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Message<String>>
getAPublisherBuilderProducingMessage()
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<String>
getAPublisherBuilderProducingPayload()
org.reactivestreams.Publisher<Message<String>>
getAPublisherProducingMessage()
org.reactivestreams.Publisher<String>
getAPublisherProducingPayload()
io.reactivex.Flowable<Message<String>>
getASubclassOfPublisherProducingMessage()
io.reactivex.Flowable<String>
getASubclassOfPublisherProducingPayload()
Message<Integer>
getMessage()
CompletionStage<Message<Integer>>
getMessageAsync()
CompletionStage<Integer>
getPayloadAsync()
int
getPayloads()
-
-
-
Method Detail
-
getAPublisherProducingMessage
public org.reactivestreams.Publisher<Message<String>> getAPublisherProducingMessage()
-
getAPublisherProducingPayload
public org.reactivestreams.Publisher<String> getAPublisherProducingPayload()
-
getAPublisherBuilderProducingMessage
public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Message<String>> getAPublisherBuilderProducingMessage()
-
getAPublisherBuilderProducingPayload
public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<String> getAPublisherBuilderProducingPayload()
-
getASubclassOfPublisherProducingMessage
public io.reactivex.Flowable<Message<String>> getASubclassOfPublisherProducingMessage()
-
getASubclassOfPublisherProducingPayload
public io.reactivex.Flowable<String> getASubclassOfPublisherProducingPayload()
-
getPayloads
public int getPayloads()
-
getMessageAsync
public CompletionStage<Message<Integer>> getMessageAsync()
-
getPayloadAsync
public CompletionStage<Integer> getPayloadAsync()
-
-