Top Inners Fields Constructors Methods
reactor.core.publisher

pack-priv final Class MonoSequenceEqual<T>

extends Mono<Boolean>
implements SourceProducer<Boolean>
Class Inheritance
All Implemented Interfaces
reactor.core.publisher.SourceProducer, org.reactivestreams.Publisher, reactor.core.Scannable
Imports
java.util.Objects, .Queue, java.util.concurrent.atomic.AtomicIntegerFieldUpdater, .AtomicReferenceFieldUpdater, java.util.function.BiPredicate, java.util.stream.Stream, org.reactivestreams.Publisher, .Subscription, reactor.core.CoreSubscriber, .Exceptions, .Scannable, reactor.util.annotation.Nullable, reactor.util.concurrent.Queues, reactor.util.context.Context

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
MonoSequenceEqual.EqualCoordinator<T>

pack-priv static class
MonoSequenceEqual.EqualSubscriber<T>

Field Summary

Modifier and TypeField and Description
pack-priv final BiPredicate<? super T, ? super T>
comparer

pack-priv final Publisher<? extends T>
first

pack-priv final int
prefetch

pack-priv final Publisher<? extends T>
second

Inherited from reactor.core.publisher.Mono:
EQUALS_BIPREDICATE

Constructor Summary

AccessConstructor and Description
pack-priv
MonoSequenceEqual(Publisher<? extends T> first, Publisher<? extends T> second, BiPredicate<? super T, ? super T> comparer, int prefetch)

Method Summary

Modifier and TypeMethod and Description
public Object
scanUnsafe(Scannable.Attr<T>
a Attr to resolve for the component.
key)

Overrides default reactor.core.publisher.SourceProducer.scanUnsafe.

This method is used internally by components to define their key-value mappings in a single place.
public void
subscribe(CoreSubscriber<? super Boolean>
the Subscriber interested into the published sequence
actual)

Implements abstract reactor.core.publisher.Mono.subscribe.

Implements reactor.core.CorePublisher.subscribe.

An internal Publisher#subscribe(Subscriber) that will bypass Hooks#onLastOperator(Function) pointcut.
Inherited from reactor.core.publisher.Mono:
andasblockblockblockOptionalblockOptionalcachecachecachecachecachecacheInvalidateIfcacheInvalidateWhencacheInvalidateWhencancelOncastcheckpointcheckpointcheckpointconcatWithcontextCapturecontextWritecontextWritecreatedefaultIfEmptydeferdeferContextualdelaydelaydelayElementdelayElementdelaySubscriptiondelaySubscriptiondelaySubscriptiondelayUntildematerializedoAfterTerminatedoFinallydoFirstdoOnCanceldoOnDiscarddoOnEachdoOnErrordoOnErrordoOnErrordoOnNextdoOnRequestdoOnSignaldoOnSubscribedoOnSuccessdoOnTerminalSignaldoOnTerminateelapsedelapsedemptyemptyequalsBiPredicateerrorerrorexpandexpandexpandDeepexpandDeepfilterfilterWhenfirstfirstfirstWithSignalfirstWithSignalfirstWithValuefirstWithValueflatMapflatMapIterableflatMapManyflatMapManyfluxfromfromCallablefromCompletionStagefromCompletionStagefromDirectfromFuturefromFuturefromFuturefromFuturefromRunnablefromSupplierhandlehasElementhideignoreElementignoreElementsjustjustOrEmptyjustOrEmptyloglogloglogloglogmapmapNotNullmaterializemergeWithmetricsnameneverofTypeonAssemblyonErrorCompleteonErrorCompleteonErrorCompleteonErrorContinueonErrorContinueonErrorContinueonErrorMaponErrorMaponErrorMaponErrorResumeonErrorResumeonErrorResumeonErrorReturnonErrorReturnonErrorReturnonErrorStoponTerminateDetachorpublishpublishOnrepeatrepeatrepeatrepeatrepeatWhenrepeatWhenEmptyrepeatWhenEmptyretryretryretryWhensequenceEqualsequenceEqualsequenceEqualsharesinglesingleOptionalsubscribesubscribesubscribesubscribesubscribesubscribesubscribesubscribeOnsubscribeWithswitchIfEmptytagtaketaketakeUntilOthertaptaptapthenthenthenEmptythenManythenReturntimedtimedtimeouttimeouttimeouttimeouttimeouttimeouttimestamptimestamptoFuturetoStringtransformtransformDeferredtransformDeferredContextualusingusingusingWhenusingWhenwhenwhenwhenDelayErrorwhenDelayErrorwrapzipzipzipzipzipzipzipzipzipzipzipDelayErrorzipDelayErrorzipDelayErrorzipDelayErrorzipDelayErrorzipDelayErrorzipDelayErrorzipDelayErrorzipDelayErrorzipWhenzipWhenzipWithzipWith

Field Detail

comparerback to summary
pack-priv final BiPredicate<? super T, ? super T> comparer
firstback to summary
pack-priv final Publisher<? extends T> first
prefetchback to summary
pack-priv final int prefetch
secondback to summary
pack-priv final Publisher<? extends T> second

Constructor Detail

MonoSequenceEqualback to summary
pack-priv MonoSequenceEqual(Publisher<? extends T> first, Publisher<? extends T> second, BiPredicate<? super T, ? super T> comparer, int prefetch)

Method Detail

scanUnsafeback to summary
public Object scanUnsafe(Scannable.Attr<T> key)

Overrides default reactor.core.publisher.SourceProducer.scanUnsafe.

Doc from reactor.core.Scannable.scanUnsafe.

This method is used internally by components to define their key-value mappings in a single place. Although it is ignoring the generic type of the Attr key, implementors should take care to return values of the correct type, and return null if no specific value is available.

For public consumption of attributes, prefer using scan(Attr), which will return a typed value and fall back to the key's default if the component didn't define any mapping.

Parameters
key:Scannable.Attr<T>

a Attr to resolve for the component.

Returns:Object

the value associated to the key for that specific component, or null if none.

Annotations
@Override
subscribeback to summary
public void subscribe(CoreSubscriber<? super Boolean> actual)

Implements abstract reactor.core.publisher.Mono.subscribe.

Implements reactor.core.CorePublisher.subscribe.

Doc from reactor.core.publisher.Mono.subscribe.

An internal Publisher#subscribe(Subscriber) that will bypass Hooks#onLastOperator(Function) pointcut.

In addition to behave as expected by Publisher#subscribe(Subscriber) in a controlled manner, it supports direct subscribe-time Context passing.

Parameters
actual:CoreSubscriber<? super Boolean>

the Subscriber interested into the published sequence

Annotations
@Override
reactor.core.publisher back to summary

pack-priv final Class MonoSequenceEqual.EqualCoordinator<T>

extends Object
implements InnerProducer<Boolean>
Class Inheritance
All Implemented Interfaces
reactor.core.publisher.InnerProducer, org.reactivestreams.Subscription, reactor.core.Scannable

Field Summary

Modifier and TypeField and Description
pack-priv final CoreSubscriber<? super Boolean>
actual

pack-priv volatile boolean
cancelled

pack-priv final BiPredicate<? super T, ? super T>
comparer

pack-priv final Publisher<? extends T>
first

pack-priv final MonoSequenceEqual.EqualSubscriber<T>
firstSubscriber

pack-priv volatile int
once

pack-priv static final AtomicIntegerFieldUpdater<MonoSequenceEqual.EqualCoordinator<T>>
ONCE

pack-priv final Publisher<? extends T>
second

pack-priv final MonoSequenceEqual.EqualSubscriber<T>
secondSubscriber

pack-priv T
v1

pack-priv T
v2

pack-priv volatile int
wip

pack-priv static final AtomicIntegerFieldUpdater<MonoSequenceEqual.EqualCoordinator<T>>
WIP

Constructor Summary

AccessConstructor and Description
pack-priv
EqualCoordinator(CoreSubscriber<? super Boolean> actual, int prefetch, Publisher<? extends T> first, Publisher<? extends T> second, BiPredicate<? super T, ? super T> comparer)

Method Summary

Modifier and TypeMethod and Description
public CoreSubscriber<? super Boolean>
actual()

Implements reactor.core.publisher.InnerProducer.actual.

public void
cancel()

Implements org.reactivestreams.Subscription.cancel.

Request the Publisher to stop sending data and clean up resources.
pack-priv void
cancel(MonoSequenceEqual.EqualSubscriber<T> s1, Queue<T> q1, MonoSequenceEqual.EqualSubscriber<T> s2, Queue<T> q2)

pack-priv void
cancelInner(MonoSequenceEqual.EqualSubscriber<T> innerSubscriber)

pack-priv void
drain()

public Stream<? extends Scannable>
inners()

Overrides default reactor.core.Scannable.inners.

Return a Stream of referenced inners (flatmap, multicast etc)
public void
request(long
the strictly positive number of elements to requests to the upstream Publisher
n)

Implements org.reactivestreams.Subscription.request.

No events will be sent by a Publisher until demand is signaled via this method.
public Object
scanUnsafe(Scannable.Attr<T>
a Attr to resolve for the component.
key)

Overrides default reactor.core.publisher.InnerProducer.scanUnsafe.

This method is used internally by components to define their key-value mappings in a single place.
pack-priv void
subscribe()

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

actualback to summary
pack-priv final CoreSubscriber<? super Boolean> actual
cancelledback to summary
pack-priv volatile boolean cancelled
comparerback to summary
pack-priv final BiPredicate<? super T, ? super T> comparer
firstback to summary
pack-priv final Publisher<? extends T> first
firstSubscriberback to summary
pack-priv final MonoSequenceEqual.EqualSubscriber<T> firstSubscriber
onceback to summary
pack-priv volatile int once
ONCEback to summary
pack-priv static final AtomicIntegerFieldUpdater<MonoSequenceEqual.EqualCoordinator<T>> ONCE
Annotations
@SuppressWarnings:rawtypes
secondback to summary
pack-priv final Publisher<? extends T> second
secondSubscriberback to summary
pack-priv final MonoSequenceEqual.EqualSubscriber<T> secondSubscriber
v1back to summary
pack-priv T v1
v2back to summary
pack-priv T v2
wipback to summary
pack-priv volatile int wip
WIPback to summary
pack-priv static final AtomicIntegerFieldUpdater<MonoSequenceEqual.EqualCoordinator<T>> WIP
Annotations
@SuppressWarnings:rawtypes

Constructor Detail

EqualCoordinatorback to summary
pack-priv EqualCoordinator(CoreSubscriber<? super Boolean> actual, int prefetch, Publisher<? extends T> first, Publisher<? extends T> second, BiPredicate<? super T, ? super T> comparer)

Method Detail

actualback to summary
public CoreSubscriber<? super Boolean> actual()

Implements reactor.core.publisher.InnerProducer.actual.

Annotations
@Override
cancelback to summary
public void cancel()

Implements org.reactivestreams.Subscription.cancel.

Doc from org.reactivestreams.Subscription.cancel.

Request the Publisher to stop sending data and clean up resources.

Data may still be sent to meet previously signalled demand after calling cancel.

Annotations
@Override
cancelback to summary
pack-priv void cancel(MonoSequenceEqual.EqualSubscriber<T> s1, Queue<T> q1, MonoSequenceEqual.EqualSubscriber<T> s2, Queue<T> q2)
cancelInnerback to summary
pack-priv void cancelInner(MonoSequenceEqual.EqualSubscriber<T> innerSubscriber)
drainback to summary
pack-priv void drain()
innersback to summary
public Stream<? extends Scannable> inners()

Overrides default reactor.core.Scannable.inners.

Doc from reactor.core.Scannable.inners.

Return a Stream of referenced inners (flatmap, multicast etc)

Returns:Stream<? extends Scannable>

a Stream of referenced inners (flatmap, multicast etc)

Annotations
@Override
requestback to summary
public void request(long n)

Implements org.reactivestreams.Subscription.request.

Doc from org.reactivestreams.Subscription.request.

No events will be sent by a Publisher until demand is signaled via this method.

It can be called however often and whenever needed—but if the outstanding cumulative demand ever becomes Long.MAX_VALUE or more, it may be treated by the Publisher as "effectively unbounded".

Whatever has been requested can be sent by the Publisher so only signal demand for what can be safely handled.

A Publisher can send less than is requested if the stream ends but then must emit either Subscriber#onError(Throwable) or Subscriber#onComplete().

Parameters
n:long

the strictly positive number of elements to requests to the upstream Publisher

Annotations
@Override
scanUnsafeback to summary
public Object scanUnsafe(Scannable.Attr<T> key)

Overrides default reactor.core.publisher.InnerProducer.scanUnsafe.

Doc from reactor.core.Scannable.scanUnsafe.

This method is used internally by components to define their key-value mappings in a single place. Although it is ignoring the generic type of the Attr key, implementors should take care to return values of the correct type, and return null if no specific value is available.

For public consumption of attributes, prefer using scan(Attr), which will return a typed value and fall back to the key's default if the component didn't define any mapping.

Parameters
key:Scannable.Attr<T>

a Attr to resolve for the component.

Returns:Object

the value associated to the key for that specific component, or null if none.

Annotations
@Override
@Nullable
subscribeback to summary
pack-priv void subscribe()
reactor.core.publisher back to summary

pack-priv final Class MonoSequenceEqual.EqualSubscriber<T>

extends Object
implements InnerConsumer<T>
Class Inheritance
All Implemented Interfaces
reactor.core.publisher.InnerConsumer, reactor.core.Scannable, reactor.core.CoreSubscriber, org.reactivestreams.Subscriber

Field Summary

Modifier and TypeField and Description
pack-priv Subscription
cachedSubscription

pack-priv volatile boolean
done

pack-priv Throwable
error

pack-priv final MonoSequenceEqual.EqualCoordinator<T>
parent

pack-priv final int
prefetch

pack-priv final Queue<T>
queue

pack-priv static final AtomicReferenceFieldUpdater<MonoSequenceEqual.EqualSubscriber<T>, Subscription>
S

pack-priv volatile Subscription
subscription

Constructor Summary

AccessConstructor and Description
pack-priv
EqualSubscriber(MonoSequenceEqual.EqualCoordinator<T> parent, int prefetch)

Method Summary

Modifier and TypeMethod and Description
public Context
currentContext()

Overrides default reactor.core.CoreSubscriber.currentContext.

Request a Context from dependent components which can include downstream operators during subscribing or a terminal org.reactivestreams.Subscriber.
public void
onComplete()

Implements org.reactivestreams.Subscriber.onComplete.

Successful terminal state.
public void
onError(Throwable
the throwable signaled
t)

Implements org.reactivestreams.Subscriber.onError.

Failed terminal state.
public void
onNext(T
the element signaled
t)

Implements org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).
public void
onSubscribe(Subscription
the Subscription that allows requesting data via Subscription#request(long)
s)

Implements reactor.core.CoreSubscriber.onSubscribe.

Implementors should initialize any state used by onNext(Object) before calling Subscription#request(long).
public Object
scanUnsafe(Scannable.Attr<T>
a Attr to resolve for the component.
key)

Implements reactor.core.Scannable.scanUnsafe.

This method is used internally by components to define their key-value mappings in a single place.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

cachedSubscriptionback to summary
pack-priv Subscription cachedSubscription
doneback to summary
pack-priv volatile boolean done
errorback to summary
pack-priv Throwable error
parentback to summary
pack-priv final MonoSequenceEqual.EqualCoordinator<T> parent
prefetchback to summary
pack-priv final int prefetch
queueback to summary
pack-priv final Queue<T> queue
Sback to summary
pack-priv static final AtomicReferenceFieldUpdater<MonoSequenceEqual.EqualSubscriber<T>, Subscription> S
subscriptionback to summary
pack-priv volatile Subscription subscription

Constructor Detail

EqualSubscriberback to summary
pack-priv EqualSubscriber(MonoSequenceEqual.EqualCoordinator<T> parent, int prefetch)

Method Detail

currentContextback to summary
public Context currentContext()

Overrides default reactor.core.CoreSubscriber.currentContext.

Doc from reactor.core.CoreSubscriber.currentContext.

Request a Context from dependent components which can include downstream operators during subscribing or a terminal org.reactivestreams.Subscriber.

Returns:Context

a resolved context or Context#empty()

Annotations
@Override
onCompleteback to summary
public void onComplete()

Implements org.reactivestreams.Subscriber.onComplete.

Doc from org.reactivestreams.Subscriber.onComplete.

Successful terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

Annotations
@Override
onErrorback to summary
public void onError(Throwable t)

Implements org.reactivestreams.Subscriber.onError.

Doc from org.reactivestreams.Subscriber.onError.

Failed terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

Parameters
t:Throwable

the throwable signaled

Annotations
@Override
onNextback to summary
public void onNext(T t)

Implements org.reactivestreams.Subscriber.onNext.

Doc from org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).

Parameters
t:T

the element signaled

Annotations
@Override
onSubscribeback to summary
public void onSubscribe(Subscription s)

Implements reactor.core.CoreSubscriber.onSubscribe.

Doc from reactor.core.CoreSubscriber.onSubscribe.

Implementors should initialize any state used by onNext(Object) before calling Subscription#request(long). Should further onNext related state modification occur, thread-safety will be required.

Note that an invalid request <= 0 will not produce an onError and will simply be ignored or reported through a debug-enabled reactor.util.Logger. Invoked after calling Publisher#subscribe(Subscriber).

No data will start flowing until Subscription#request(long) is invoked.

It is the responsibility of this Subscriber instance to call Subscription#request(long) whenever more data is wanted.

The Publisher will send notifications only in response to Subscription#request(long).

Parameters
s:Subscription

Doc from org.reactivestreams.Subscriber.onSubscribe.

the Subscription that allows requesting data via Subscription#request(long)

Annotations
@Override
scanUnsafeback to summary
public Object scanUnsafe(Scannable.Attr<T> key)

Implements reactor.core.Scannable.scanUnsafe.

Doc from reactor.core.Scannable.scanUnsafe.

This method is used internally by components to define their key-value mappings in a single place. Although it is ignoring the generic type of the Attr key, implementors should take care to return values of the correct type, and return null if no specific value is available.

For public consumption of attributes, prefer using scan(Attr), which will return a typed value and fall back to the key's default if the component didn't define any mapping.

Parameters
key:Scannable.Attr<T>

a Attr to resolve for the component.

Returns:Object

the value associated to the key for that specific component, or null if none.

Annotations
@Override
@Nullable