Package com.hivemq.client.rx.reactivestreams

Interface WithSingleSubscriber<T,S>

All Superinterfaces:

Subscriber<T>

All Known Subinterfaces:

FlowableWithSingleSubscriber<F,S>

public interface WithSingleSubscriber<T,S>
extends Subscriber<T>

A Subscriber which consumes also a single item of type WithSingleSubscriber by onSingle(Object) besides items of type WithSingleSubscriber by Subscriber.onNext(Object).

See Also:

• Subscriber

Method Summary

Modifier and Type	Method	Description
void	onSingle(S s)	Single item sent by the PublisherWithSingle.

Methods inherited from interface org.reactivestreams.Subscriber

onComplete, onError, onNext, onSubscribe

Method Details

onSingle

void onSingle(@NotNull
 S s)

Single item sent by the PublisherWithSingle.

Parameters:

s - the single item.