io.micronaut.nats.reactive

Class RxJavaReactivePublisher

java.lang.Object

io.micronaut.nats.reactive.RxJavaReactivePublisher

All Implemented Interfaces:

ReactivePublisher

@Internal
 @EachBean(value=io.nats.client.Connection.class)
public class RxJavaReactivePublisher
extends java.lang.Object
implements ReactivePublisher

Author:

jgrimm

Constructor Summary

Constructors

Constructor and Description
RxJavaReactivePublisher(io.nats.client.Connection connection) Constructor.

Method Summary

Modifier and Type	Method and Description
org.reactivestreams.Publisher<java.lang.Void>	publish(PublishState publishState) Publish the message with the provided arguments and return a reactive type that completes successfully when the message is published.
org.reactivestreams.Publisher<io.nats.client.Message>	publishAndReply(PublishState publishState) Publish the message with the provided arguments and return a reactive type that completes successfully when the reply is received from the reply to queue.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RxJavaReactivePublisher

public RxJavaReactivePublisher(@Parameter
                               io.nats.client.Connection connection)

Constructor.

Parameters:

connection - The given connection

Method Detail

publish

public org.reactivestreams.Publisher<java.lang.Void> publish(PublishState publishState)

Description copied from interface: ReactivePublisher

Publish the message with the provided arguments and return a reactive type that completes successfully when the message is published.

Specified by:

publish in interface ReactivePublisher

Parameters:

publishState - The publishing data

Returns:

the publisher

publishAndReply

public org.reactivestreams.Publisher<io.nats.client.Message> publishAndReply(PublishState publishState)

Description copied from interface: ReactivePublisher

Publish the message with the provided arguments and return a reactive type that completes successfully when the reply is received from the reply to queue.

Specified by:

publishAndReply in interface ReactivePublisher

Parameters:

publishState - The publishing data

Returns:

The publisher of the received reply