Package com.hivemq.client.rx.reactivestreams

Interface PublisherWithSingle<T,S>

Type Parameters:

T - the type of the stream of items.

S - the type of the single item.

All Superinterfaces:

Publisher<T>

All Known Implementing Classes:

FlowableWithSingle

public interface PublisherWithSingle<T,S>
extends Publisher<T>

A Publisher which emits a flow of items of type PublisherWithSingle and a single item of type PublisherWithSingle.

See Also:

• Publisher

Method Summary

Modifier and Type	Method	Description
void	subscribeBoth(@NotNull WithSingleSubscriber<? super T,? super S> subscriber)	Subscribes to this PublisherWithSingle.

Methods inherited from interface org.reactivestreams.Publisher

subscribe

Method Details

subscribeBoth

void subscribeBoth(@NotNull
 @NotNull WithSingleSubscriber<? super T,? super S> subscriber)

Subscribes to this PublisherWithSingle.

In addition to signalling the stream of items via onNext, the single item is signalled via onSingle.

Parameters:

subscriber - the WithSingleSubscriber that will consume signals from this PublisherWithSingle.

See Also:

• Publisher.subscribe(Subscriber)