reactor.core.publisher

Class MonoSequenceEqual<T>

java.lang.Object

reactor.core.publisher.Mono<java.lang.Boolean>

reactor.core.publisher.MonoSequenceEqual<T>

All Implemented Interfaces:

org.reactivestreams.Publisher<java.lang.Boolean>

public class MonoSequenceEqual<T>
extends Mono<java.lang.Boolean>

Constructor Summary

Constructors

Constructor and Description
MonoSequenceEqual(org.reactivestreams.Publisher<? extends T> first, org.reactivestreams.Publisher<? extends T> second, java.util.function.BiPredicate<? super T,? super T> comparer, int bufferSize)

Method Summary

Modifier and Type	Method and Description
void	subscribe(org.reactivestreams.Subscriber<? super java.lang.Boolean> s)

Methods inherited from class reactor.core.publisher.Mono

and, as, awaitOnSubscribe, block, block, blockMillis, cache, cancelOn, cast, compose, concatWith, create, defaultIfEmpty, defer, delay, delayMillis, delayMillis, delaySubscription, delaySubscription, delaySubscriptionMillis, delaySubscriptionMillis, dematerialize, doAfterTerminate, doOnCancel, doOnError, doOnError, doOnError, doOnNext, doOnRequest, doOnSubscribe, doOnSuccess, doOnTerminate, elapsed, elapsed, empty, empty, error, filter, first, first, flatMap, flatMap, flatMapIterable, flux, from, fromCallable, fromFuture, fromRunnable, fromSupplier, handle, hasElement, hide, ignoreElement, ignoreElements, just, justOrEmpty, justOrEmpty, log, log, log, log, map, mapError, mapError, mapError, materialize, mergeWith, never, ofType, onAssembly, onTerminateDetach, or, otherwise, otherwise, otherwise, otherwiseIfEmpty, otherwiseReturn, otherwiseReturn, otherwiseReturn, publish, publishOn, repeat, repeat, repeat, repeat, repeatWhen, repeatWhenEmpty, repeatWhenEmpty, retry, retry, retry, retry, retryWhen, sequenceEqual, sequenceEqual, sequenceEqual, subscribe, subscribe, subscribe, subscribe, subscribeOn, subscribeWith, then, then, then, then, thenMany, thenMany, timeout, timeout, timeout, timeout, timeoutMillis, timeoutMillis, timeoutMillis, timeoutMillis, timestamp, timestamp, toFuture, toString, transform, using, using, when, when, when, when, when, when, when, when, when, whenDelayError, whenDelayError, whenDelayError, whenDelayError, whenDelayError, whenDelayError, whenDelayError, zip, zip

Methods inherited from class java.lang.Object

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

Constructor Detail

MonoSequenceEqual

public MonoSequenceEqual(org.reactivestreams.Publisher<? extends T> first,
                         org.reactivestreams.Publisher<? extends T> second,
                         java.util.function.BiPredicate<? super T,? super T> comparer,
                         int bufferSize)

Method Detail

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super java.lang.Boolean> s)