com_baeldung_reactor_core_CombiningPublishersIntegrationTest_java
reactor.core.publisher.Flux
 -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Queue.peek(): java.lang.Object -> java.util.Queue.peek(): java.lang.Object -> java.util.Queue.poll(): java.lang.Object -> java.util.function.BiFunction.apply(java.lang.Object,java.lang.Object): java.lang.Object -> java.util.Optional.empty(): java.util.Optional -> java.util.Optional.isPresent(): boolean -> java.util.Queue.peek(): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.get(java.lang.Object): long -> java.util.concurrent.atomic.AtomicLongFieldUpdater.compareAndSet(java.lang.Object,long,long): boolean -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.getAndIncrement(java.lang.Object): int -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.addAndGet(java.lang.Object,int): int -> java.util.concurrent.atomic.AtomicLongFieldUpdater.get(java.lang.Object): long -> java.util.concurrent.atomic.AtomicLongFieldUpdater.compareAndSet(java.lang.Object,long,long): boolean -> java.util.function.Function.apply(java.lang.Object): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.lang.System.arraycopy(java.lang.Object,int,java.lang.Object,int,int): void -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.lazySet(java.lang.Object,int): void -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.lazySet(java.lang.Object,int): void -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.function.Supplier.get(): java.lang.Object -> java.lang.Integer.numberOfLeadingZeros(int): int -> java.util.function.Function.apply(java.lang.Object): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.concurrent.atomic.AtomicReferenceFieldUpdater.get(java.lang.Object): java.lang.Object -> java.util.concurrent.atomic.AtomicReferenceFieldUpdater.compareAndSet(java.lang.Object,java.lang.Object,java.lang.Object): boolean -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.compareAndSet(java.lang.Object,int,int): boolean -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.decrementAndGet(java.lang.Object): int -> java.util.concurrent.atomic.AtomicLongFieldUpdater.get(java.lang.Object): long -> java.util.concurrent.atomic.AtomicLongFieldUpdater.compareAndSet(java.lang.Object,long,long): boolean -> java.lang.Integer.valueOf(int): java.lang.Integer -> java.util.function.Predicate.test(java.lang.Object): boolean -> java.lang.Integer.intValue(): int -> java.lang.Integer.valueOf(int): java.lang.Integer -> java.util.function.Predicate.test(java.lang.Object): boolean -> java.lang.Integer.intValue(): int -> java.util.Queue.offer(java.lang.Object): boolean -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet(java.lang.Object,long): void -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.getAndIncrement(java.lang.Object): int -> java.util.Queue.poll(): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet(java.lang.Object,long): void -> java.util.function.Function.apply(java.lang.Object): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object): java.lang.Object -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.compareAndSet(java.lang.Object,int,int): boolean -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.decrementAndGet(java.lang.Object): int -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.compareAndSet(java.lang.Object,int,int): boolean -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.compareAndSet(java.lang.Object,int,int): boolean -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.compareAndSet(java.lang.Object,int,int): boolean -> java.util.function.Function.apply(java.lang.Object): java.lang.Object -> java.time.Duration.toNanos(): long -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.lang.Boolean.valueOf(boolean): java.lang.Boolean -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.compareAndSet(java.lang.Object,int,int): boolean -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.compareAndSet(java.lang.Object,int,int): boolean -> java.util.concurrent.atomic.AtomicReferenceFieldUpdater.lazySet(java.lang.Object,java.lang.Object): void -> java.util.concurrent.ScheduledExecutorService.schedule(java.util.concurrent.Callable,long,java.util.concurrent.TimeUnit): java.util.concurrent.ScheduledFuture -> java.lang.StringBuilder.append(java.lang.String): java.lang.StringBuilder -> java.lang.StringBuilder.append(java.lang.String): java.lang.StringBuilder -> java.util.concurrent.atomic.AtomicLong.incrementAndGet(): long -> java.lang.StringBuilder.append(long): java.lang.StringBuilder -> java.lang.StringBuilder.toString(): java.lang.String -> java.lang.Thread.setDaemon(boolean): void -> java.lang.Thread.setUncaughtExceptionHandler(java.lang.Thread$UncaughtExceptionHandler): void -> java.util.concurrent.atomic.AtomicReferenceFieldUpdater.compareAndSet(java.lang.Object,java.lang.Object,java.lang.Object): boolean -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.compareAndSet(java.lang.Object,int,int): boolean -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.decrementAndGet(java.lang.Object): int -> java.lang.Integer.valueOf(int): java.lang.Integer -> java.util.function.Predicate.test(java.lang.Object): boolean -> java.lang.Integer.intValue(): int -> java.lang.Integer.valueOf(int): java.lang.Integer -> java.util.function.Predicate.test(java.lang.Object): boolean -> java.lang.Integer.intValue(): int -> java.util.Queue.offer(java.lang.Object): boolean -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet(java.lang.Object,long): void -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.getAndIncrement(java.lang.Object): int -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.decrementAndGet(java.lang.Object): int -> java.lang.Integer.valueOf(int): java.lang.Integer -> java.util.function.Predicate.test(java.lang.Object): boolean -> java.lang.Integer.intValue(): int -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.getAndIncrement(java.lang.Object): int -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.decrementAndGet(java.lang.Object): int -> java.util.function.Function.apply(java.lang.Object): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.lazySet(java.lang.Object,int): void -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.lazySet(java.lang.Object,int): void -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.function.Supplier.get(): java.lang.Object -> java.lang.Integer.numberOfLeadingZeros(int): int -> java.util.function.Function.apply(java.lang.Object): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.concurrent.atomic.AtomicReferenceFieldUpdater.get(java.lang.Object): java.lang.Object -> java.util.concurrent.atomic.AtomicReferenceFieldUpdater.compareAndSet(java.lang.Object,java.lang.Object,java.lang.Object): boolean -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.compareAndSet(java.lang.Object,int,int): boolean -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.decrementAndGet(java.lang.Object): int -> java.util.concurrent.atomic.AtomicLongFieldUpdater.get(java.lang.Object): long -> java.util.concurrent.atomic.AtomicLongFieldUpdater.compareAndSet(java.lang.Object,long,long): boolean -> java.lang.Integer.valueOf(int): java.lang.Integer -> java.util.function.Predicate.test(java.lang.Object): boolean -> java.lang.Integer.intValue(): int -> java.util.Queue.offer(java.lang.Object): boolean -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet(java.lang.Object,long): void -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.getAndIncrement(java.lang.Object): int -> java.util.Queue.poll(): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet(java.lang.Object,long): void -> java.util.function.Function.apply(java.lang.Object): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object): java.lang.Object -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.compareAndSet(java.lang.Object,int,int): boolean -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.decrementAndGet(java.lang.Object): int -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.compareAndSet(java.lang.Object,int,int): boolean -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.compareAndSet(java.lang.Object,int,int): boolean -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.compareAndSet(java.lang.Object,int,int): boolean -> java.util.function.Function.apply(java.lang.Object): java.lang.Object -> java.time.Duration.toNanos(): long -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.lang.Boolean.valueOf(boolean): java.lang.Boolean -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.compareAndSet(java.lang.Object,int,int): boolean -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.compareAndSet(java.lang.Object,int,int): boolean -> java.util.concurrent.atomic.AtomicReferenceFieldUpdater.lazySet(java.lang.Object,java.lang.Object): void -> java.util.concurrent.ScheduledExecutorService.schedule(java.util.concurrent.Callable,long,java.util.concurrent.TimeUnit): java.util.concurrent.ScheduledFuture -> java.lang.StringBuilder.append(java.lang.String): java.lang.StringBuilder -> java.lang.StringBuilder.append(java.lang.String): java.lang.StringBuilder -> java.util.concurrent.atomic.AtomicLong.incrementAndGet(): long -> java.lang.StringBuilder.append(long): java.lang.StringBuilder -> java.lang.StringBuilder.toString(): java.lang.String -> java.lang.Thread.setDaemon(boolean): void -> java.lang.Thread.setUncaughtExceptionHandler(java.lang.Thread$UncaughtExceptionHandler): void -> java.util.concurrent.atomic.AtomicReferenceFieldUpdater.compareAndSet(java.lang.Object,java.lang.Object,java.lang.Object): boolean -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.compareAndSet(java.lang.Object,int,int): boolean -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.decrementAndGet(java.lang.Object): int -> java.lang.Integer.valueOf(int): java.lang.Integer -> java.util.function.Predicate.test(java.lang.Object): boolean -> java.lang.Integer.intValue(): int -> java.lang.Integer.valueOf(int): java.lang.Integer -> java.util.function.Predicate.test(java.lang.Object): boolean -> java.lang.Integer.intValue(): int -> java.util.Queue.offer(java.lang.Object): boolean -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet(java.lang.Object,long): void -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.getAndIncrement(java.lang.Object): int -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.decrementAndGet(java.lang.Object): int -> java.lang.Integer.valueOf(int): java.lang.Integer -> java.util.function.Predicate.test(java.lang.Object): boolean -> java.lang.Integer.intValue(): int -> java.lang.Integer.valueOf(int): java.lang.Integer -> java.util.function.Predicate.test(java.lang.Object): boolean -> java.lang.Integer.intValue(): int -> java.util.Queue.offer(java.lang.Object): boolean -> java.util.Objects.requireNonNull(java.lang.Object,java.lang.String): java.lang.Object -> java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet(java.lang.Object,long): void -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.getAndIncrement(java.lang.Object): int -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.decrementAndGet(java.lang.Object): int -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.getAndIncrement(java.lang.Object): int -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.decrementAndGet(java.lang.Object): int -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.getAndIncrement(java.lang.Object): int -> java.util.concurrent.atomic.AtomicIntegerFieldUpdater.addAndGet(java.lang.Object,int): int