Source file "reactor/core/publisher/Operators.java" was not found during generation of report.
| Element | Missed Instructions | Cov. | Missed Branches | Cov. | Missed | Cxty | Missed | Lines | Missed | Methods |
| Total | 1,138 of 1,138 | 0% | 190 of 190 | 0% | 166 | 166 | 362 | 362 | 71 | 71 |
| onDiscardQueueWithClear(Queue, Context, Function) | | 0% | | 0% | 5 | 5 | 24 | 24 | 1 | 1 |
| setOnce(AtomicReferenceFieldUpdater, Object, Subscription) | | 0% | | 0% | 5 | 5 | 18 | 18 | 1 | 1 |
| onDiscardMultiple(Collection, Context) | | 0% | | 0% | 6 | 6 | 16 | 16 | 1 | 1 |
| onOperatorError(Subscription, Throwable, Object, Context) | | 0% | | 0% | 7 | 7 | 14 | 14 | 1 | 1 |
| onNextDropped(Object, Context) | | 0% | | 0% | 4 | 4 | 10 | 10 | 1 | 1 |
| producedCancellable(AtomicLongFieldUpdater, Object, long) | | 0% | | 0% | 5 | 5 | 12 | 12 | 1 | 1 |
| onRejectedExecution(Throwable, Subscription, Throwable, Object, Context) | | 0% | | 0% | 4 | 4 | 8 | 8 | 1 | 1 |
| onNextPollError(Object, Throwable, Context) | | 0% | | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
| onNextErrorStrategy(Context) | | 0% | | 0% | 5 | 5 | 9 | 9 | 1 | 1 |
| onNextError(Object, Throwable, Context, Subscription) | | 0% | | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
| onNextInnerError(Throwable, Context, Subscription) | | 0% | | 0% | 4 | 4 | 8 | 8 | 1 | 1 |
| addCapCancellable(AtomicLongFieldUpdater, Object, long) | | 0% | | 0% | 4 | 4 | 7 | 7 | 1 | 1 |
| produced(AtomicLongFieldUpdater, Object, long) | | 0% | | 0% | 4 | 4 | 6 | 6 | 1 | 1 |
| onDiscardMultiple(Iterator, boolean, Context) | | 0% | | 0% | 4 | 4 | 9 | 9 | 1 | 1 |
| onDiscardMultiple(Spliterator, boolean, Context) | | 0% | | 0% | 4 | 4 | 9 | 9 | 1 | 1 |
| set(AtomicReferenceFieldUpdater, Object, Subscription) | | 0% | | 0% | 4 | 4 | 9 | 9 | 1 | 1 |
| terminate(AtomicReferenceFieldUpdater, Object) | | 0% | | 0% | 4 | 4 | 7 | 7 | 1 | 1 |
| onLastAssembly(CorePublisher) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| onNextError(Object, Throwable, Context) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| addCap(AtomicLongFieldUpdater, Object, long) | | 0% | | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
| multiplyCap(long, long) | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
| onDiscardMultiple(Stream, Context) | | 0% | | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
| onErrorDropped(Throwable, Context) | | 0% | | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
| replace(AtomicReferenceFieldUpdater, Object, Subscription) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| onDiscard(Object, Context) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| lambda$discardLocalAdapter$1(Consumer, Context) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| toCoreSubscriber(Subscriber) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| toConditionalSubscriber(CoreSubscriber) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| reportThrowInSubscribe(CoreSubscriber, Throwable) | | 0% | n/a | 1 | 1 | 7 | 7 | 1 | 1 | |
| unboundedOrLimit(int, int) | | 0% | | 0% | 4 | 4 | 5 | 5 | 1 | 1 |
| discardLocalAdapter(Class, Consumer) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| enableOnDiscard(Context, Consumer) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| addCap(long, long) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| subOrZero(long, long) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| validate(Subscription, Subscription) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| lambda$onDiscardMultiple$5(Consumer, Object) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| lambda$onDiscardMultiple$4(Consumer, Object) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| multiSubscribersContext(InnerProducer[]) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| unboundedOrLimit(int) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| validate(long) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| lambda$onDiscardMultiple$3(Consumer, Object) | | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | |
| lambda$onDiscardQueueWithClear$2(Consumer, Object) | | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | |
| lambda$discardLocalAdapter$0(Class, Consumer, Object) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| reportBadRequest(long) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| as(Subscription) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| unwrapOnNextError(Throwable) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| reportMoreProduced() | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| reportSubscriptionSet() | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| unboundedOrPrefetch(int) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| static {...} | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| canAppearAfterOnSubscribe(Subscription) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| error(Subscriber, Throwable) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| onRejectedExecution(Throwable, Context) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| scalarSubscription(CoreSubscriber, Object, String) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| complete(Subscriber) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| onOperatorError(Subscription, Throwable, Context) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| scalarSubscription(CoreSubscriber, Object) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| onOperatorError(Throwable, Context) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| serialize(CoreSubscriber) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| onErrorDroppedMulticast(Throwable, InnerProducer[]) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| onNextDroppedMulticast(Object, InnerProducer[]) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| lift(BiFunction) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lift(Predicate, BiFunction) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| liftPublisher(BiFunction) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| liftPublisher(Predicate, BiFunction) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| onNextErrorFunction(Context) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| Operators() | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| cancelledSubscription() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| drainSubscriber() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| emptySubscriber() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| emptySubscription() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 |