Uses of Class
io.helidon.messaging.Channel

Packages that use Channel

Package	Description
io.helidon.messaging	Helidon Reactive Messaging.

Uses of Channel in io.helidon.messaging

Methods in io.helidon.messaging that return Channel

Modifier and Type	Method	Description
Channel<PAYLOAD>	Channel.Builder.build()
static <PAYLOAD> Channel<PAYLOAD>	Channel.create()	Create new empty channel with random name.
static <PAYLOAD> Channel<PAYLOAD>	Channel.create(String name)	Create new empty channel with given name.
Channel<PAYLOAD>	Channel.Builder.get()

Methods in io.helidon.messaging with parameters of type Channel

Modifier and Type	Method	Description
Emitter.Builder<PAYLOAD>	Emitter.Builder.channel(Channel<PAYLOAD> channel)	Add new Channel for Emitter to publish to.
static <PAYLOAD> Emitter<PAYLOAD>	Emitter.create(Channel<PAYLOAD> channel)	Create new Emitter to serve as a publisher for supplied channel.
static <PAYLOAD> Emitter<PAYLOAD>	Emitter.create(Channel<PAYLOAD> channel, Channel<PAYLOAD>... channels)	Create new Emitter to serve as a broadcast publisher for supplied channels.
<PAYLOAD> Messaging.Builder	Messaging.Builder.listener(Channel<PAYLOAD> channel, Consumer<? super PAYLOAD> consumer)	Register Consumer for listening every payload coming from upstream.
<PAYLOAD,RESULT> Messaging.Builder	Messaging.Builder.processor(Channel<PAYLOAD> in, Channel<RESULT> out, Function<? super PAYLOAD,? extends RESULT> messageFunction)	Register a mapping function between two channels.
<PAYLOAD,RESULT> Messaging.Builder	Messaging.Builder.processor(Channel<PAYLOAD> in, Channel<RESULT> out, ProcessorBuilder<? extends Message<? extends PAYLOAD>,? extends Message<? extends RESULT>> processorBuilder)	Register ProcessorBuilder for building Processor to be used is in Channel's subscriber and out Channel's publisher.
<PAYLOAD,RESULT> Messaging.Builder	Messaging.Builder.processor(Channel<PAYLOAD> in, Channel<RESULT> out, Processor<? extends Message<? extends PAYLOAD>,? extends Message<? extends RESULT>> processor)	Register Processor to be used is in Channel's subscriber and out Channel's publisher.
<PAYLOAD> Messaging.Builder	Messaging.Builder.publisher(Channel<PAYLOAD> channel, Flow.Publisher<? extends Message<? extends PAYLOAD>> publisher)	Register Flow.Publisher to be used for supplied Channel.
<PAYLOAD> Messaging.Builder	Messaging.Builder.publisher(Channel<PAYLOAD> channel, Flow.Publisher<? extends PAYLOAD> publisher, Function<? super PAYLOAD,? extends Message<? extends PAYLOAD>> wrapper)	Register Flow.Publisher to be used for supplied Channel.
<PAYLOAD> Messaging.Builder	Messaging.Builder.publisher(Channel<PAYLOAD> channel, PublisherBuilder<? extends Message<? extends PAYLOAD>> publisherBuilder)	Register PublisherBuilder to be used for construction of the publisher for supplied Channel.
<PAYLOAD> Messaging.Builder	Messaging.Builder.publisher(Channel<PAYLOAD> channel, Publisher<? extends Message<? extends PAYLOAD>> publisher)	Register Publisher to be used for supplied Channel.
<PAYLOAD> Messaging.Builder	Messaging.Builder.publisher(Channel<PAYLOAD> channel, Publisher<? extends PAYLOAD> publisher, Function<? super PAYLOAD,? extends Message<? extends PAYLOAD>> wrapper)	Register Publisher to be used for supplied Channel.
<PAYLOAD> Messaging.Builder	Messaging.Builder.subscriber(Channel<PAYLOAD> channel, Flow.Subscriber<? extends Message<? extends PAYLOAD>> subscriber)	Register Flow.Subscriber to be used for supplied Channel.
<PAYLOAD> Messaging.Builder	Messaging.Builder.subscriber(Channel<PAYLOAD> channel, Consumer<Multi<? extends Message<? extends PAYLOAD>>> consumer)	Use provided Multi to subscribe to supplied Channel.
<PAYLOAD,RESULT> Messaging.Builder	Messaging.Builder.subscriber(Channel<PAYLOAD> channel, SubscriberBuilder<? extends Message<? extends PAYLOAD>,RESULT> subscriberBuilder)	Register SubscriberBuilder to be used for creating Subscriber for supplied Channel.
<PAYLOAD> Messaging.Builder	Messaging.Builder.subscriber(Channel<PAYLOAD> channel, Subscriber<? extends Message<? extends PAYLOAD>> subscriber)	Register Subscriber to be used for supplied Channel.