@ApplicationScoped public class PublisherBean extends Object
Constructor and Description |
---|
PublisherBean() |
Modifier and Type | Method and 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() |
public org.reactivestreams.Publisher<Message<String>> getAPublisherProducingMessage()
public org.reactivestreams.Publisher<String> getAPublisherProducingPayload()
public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<Message<String>> getAPublisherBuilderProducingMessage()
public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<String> getAPublisherBuilderProducingPayload()
public io.reactivex.Flowable<Message<String>> getASubclassOfPublisherProducingMessage()
public io.reactivex.Flowable<String> getASubclassOfPublisherProducingPayload()
public int getPayloads()
public CompletionStage<Message<Integer>> getMessageAsync()
public CompletionStage<Integer> getPayloadAsync()
Copyright © 2018 – 2022 Eclipse Foundation. All rights reserved.
Use is subject to license terms.