Source file "org/osgi/util/pushstream/AbstractPushStreamImpl.java" was not found during generation of report.
| Element | Missed Instructions | Cov. | Missed Branches | Cov. | Missed | Cxty | Missed | Lines | Missed | Methods |
| Total | 2,997 of 2,997 | 0% | 222 of 222 | 0% | 239 | 239 | 759 | 759 | 117 | 117 |
| lambda$window$39(AbstractPushStreamImpl, Object, AtomicReference, AtomicBoolean, AtomicLong, AtomicLong, BiFunction, Executor, IntSupplier, Supplier, AtomicLong, PushEvent) | | 0% | | 0% | 8 | 8 | 42 | 42 | 1 | 1 |
| lambda$split$28(Predicate[], AtomicReferenceArray, AbstractPushStreamImpl[], AtomicInteger, PushEvent) | | 0% | | 0% | 9 | 9 | 28 | 28 | 1 | 1 |
| lambda$getWindowTask$41(Object, AtomicLong, long, AtomicLong, AtomicReference, Executor, AbstractPushStreamImpl, BiFunction, Supplier, AtomicLong, IntSupplier) | | 0% | | 0% | 3 | 3 | 19 | 19 | 1 | 1 |
| lambda$coalesce$33(Object, AtomicReference, AtomicBoolean, IntSupplier, Function, AbstractPushStreamImpl, PushEvent) | | 0% | | 0% | 6 | 6 | 26 | 26 | 1 | 1 |
| close(PushEvent, boolean) | | 0% | | 0% | 8 | 8 | 24 | 24 | 1 | 1 |
| window(Supplier, IntSupplier, Executor, BiFunction) | | 0% | n/a | 1 | 1 | 12 | 12 | 1 | 1 | |
| lambda$collect$52(Object, BiConsumer, Collector, Deferred, PushEvent) | | 0% | | 0% | 5 | 5 | 24 | 24 | 1 | 1 |
| split(Predicate[]) | | 0% | | 0% | 2 | 2 | 10 | 10 | 1 | 1 |
| lambda$collect$51(BiConsumer, Object, Collector, Deferred, PushEvent) | | 0% | | 0% | 5 | 5 | 22 | 22 | 1 | 1 |
| lambda$asyncMap$7(Semaphore, int, AbstractPushStreamImpl, Function, int, PushEvent) | | 0% | | 0% | 2 | 2 | 13 | 13 | 1 | 1 |
| lambda$forEachEvent$60(PushEventConsumer, LongAdder, Deferred, PushEvent) | | 0% | | 0% | 4 | 4 | 19 | 19 | 1 | 1 |
| lambda$sorted$10(List, Comparator, AbstractPushStreamImpl, PushEvent) | | 0% | | 0% | 6 | 6 | 15 | 15 | 1 | 1 |
| lambda$window$37(Object, AtomicLong, AtomicLong, Supplier, AtomicLong, BiFunction, IntSupplier, AtomicReference, Executor, AbstractPushStreamImpl) | | 0% | n/a | 1 | 1 | 10 | 10 | 1 | 1 | |
| handleEvent(PushEvent) | | 0% | | 0% | 5 | 5 | 15 | 15 | 1 | 1 |
| merge(PushEventSource) | | 0% | n/a | 1 | 1 | 11 | 11 | 1 | 1 | |
| lambda$reduce$48(AtomicReference, BinaryOperator, Deferred, PushEvent) | | 0% | | 0% | 5 | 5 | 12 | 12 | 1 | 1 |
| lambda$merge$25(AbstractPushStreamImpl, AtomicInteger, PushStream, PushEvent) | | 0% | | 0% | 4 | 4 | 17 | 17 | 1 | 1 |
| lambda$flatMap$8(AbstractPushStreamImpl, PushEvent) | | 0% | | 0% | 5 | 5 | 11 | 11 | 1 | 1 |
| lambda$coalesce$30(Function, AbstractPushStreamImpl, PushEvent) | | 0% | | 0% | 3 | 3 | 13 | 13 | 1 | 1 |
| coalesce(IntSupplier, Function) | | 0% | n/a | 1 | 1 | 7 | 7 | 1 | 1 | |
| collect(Collector) | | 0% | | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
| lambda$findFirst$59(Deferred, PushEvent) | | 0% | | 0% | 5 | 5 | 14 | 14 | 1 | 1 |
| check(AtomicLong, long) | | 0% | | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
| lambda$reduce$50(AtomicReference, BiFunction, Deferred, PushEvent) | | 0% | | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
| lambda$reduce$47(AtomicReference, BinaryOperator, Deferred, PushEvent) | | 0% | | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
| lambda$fork$19(Semaphore, int, AbstractPushStreamImpl, Executor, int, PushEvent) | | 0% | | 0% | 2 | 2 | 10 | 10 | 1 | 1 |
| lambda$limit$11(AtomicLong, AbstractPushStreamImpl, PushEvent) | | 0% | | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
| lambda$count$55(LongAdder, Deferred, PushEvent) | | 0% | | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
| lambda$forEach$45(Consumer, Deferred, PushEvent) | | 0% | | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
| lambda$aggregateAndForward$42(Queue, PushEvent, AbstractPushStreamImpl, BiFunction, long) | | 0% | | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
| lambda$merge$22(AbstractPushStreamImpl, AtomicInteger, PushEvent) | | 0% | | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
| AbstractPushStreamImpl(PushStreamProvider, PromiseFactory) | | 0% | n/a | 1 | 1 | 9 | 9 | 1 | 1 | |
| fork(int, int, Executor) | | 0% | n/a | 1 | 1 | 6 | 6 | 1 | 1 | |
| lambda$skip$17(AtomicLong, AbstractPushStreamImpl, PushEvent) | | 0% | | 0% | 4 | 4 | 8 | 8 | 1 | 1 |
| updateNext(PushEventConsumer) | | 0% | | 0% | 4 | 4 | 8 | 8 | 1 | 1 |
| limit(long) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| skip(long) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| merge(PushStream) | | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | |
| lambda$adjustBackPressure$44(AbstractPushStreamImpl, ToLongBiFunction, PushEvent) | | 0% | | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
| lambda$fork$18(AbstractPushStreamImpl, PushEvent, Semaphore) | | 0% | | 0% | 2 | 2 | 10 | 10 | 1 | 1 |
| lambda$window$38(AbstractPushStreamImpl, BiFunction, long, Collection, PushEvent) | | 0% | n/a | 1 | 1 | 11 | 11 | 1 | 1 | |
| lambda$flatMap$9(Function, PushEventConsumer, AbstractPushStreamImpl, PushEvent) | | 0% | | 0% | 2 | 2 | 10 | 10 | 1 | 1 |
| onClose(Runnable) | | 0% | | 0% | 4 | 4 | 5 | 5 | 1 | 1 |
| lambda$adjustBackPressure$43(AbstractPushStreamImpl, LongUnaryOperator, PushEvent) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| timeout(Duration) | | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | |
| lambda$filter$1(Predicate, AbstractPushStreamImpl, PushEvent) | | 0% | | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
| asyncMap(int, int, Function) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| lambda$getWindowTask$40(AbstractPushStreamImpl, BiFunction, long, Collection) | | 0% | n/a | 1 | 1 | 8 | 8 | 1 | 1 | |
| lambda$map$2(AbstractPushStreamImpl, Function, PushEvent) | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| onError(Consumer) | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
| sorted(Comparator) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| flatMap(Function) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| limit(Duration) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| reduce(Object, BinaryOperator) | | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | |
| reduce(BinaryOperator) | | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | |
| reduce(Object, BiFunction, BinaryOperator) | | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | |
| sequential() | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| forEachEvent(PushEventConsumer) | | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | |
| count() | | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | |
| lambda$asyncMap$3(AbstractPushStreamImpl, Object, Semaphore) | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| lambda$sequential$29(Lock, AbstractPushStreamImpl, PushEvent) | | 0% | n/a | 1 | 1 | 6 | 6 | 1 | 1 | |
| filter(Predicate) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| map(Function) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| coalesce(Function) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| aggregateAndForward(Function, AbstractPushStreamImpl, PushEvent, Queue) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| adjustBackPressure(LongUnaryOperator) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| adjustBackPressure(ToLongBiFunction) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| forEach(Consumer) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| findFirst() | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| lambda$merge$26(AtomicInteger, PushStream, AbstractPushStreamImpl) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| getWindowTask(AbstractPushStreamImpl, BiFunction, Supplier, IntSupplier, Object, long, AtomicReference, AtomicLong, AtomicLong, AtomicLong, Executor) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| distinct() | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| coalesce(int, Function) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| getQueueForInternalBuffering(int) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| lambda$merge$27(PushStream) | | 0% | n/a | 1 | 1 | 9 | 9 | 1 | 1 | |
| lambda$timeout$15(AbstractPushStreamImpl, PushEvent) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| lambda$limit$14(AbstractPushStreamImpl, PushEvent) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| close() | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| lambda$limit$13(Duration) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| lambda$asyncMap$5(Throwable) | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| aggregateAndForward(BiFunction, AbstractPushStreamImpl, PushEvent, Queue, Executor, long) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| lambda$window$36(Function, Long, Collection) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| lambda$asyncMap$4(AbstractPushStreamImpl, Semaphore, Object) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| window(Duration, Executor, Function) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| window(Supplier, IntSupplier, BiFunction) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| toArray(IntFunction) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| lambda$max$54(Comparator, Object, Object) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$min$53(Comparator, Object, Object) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| window(Duration, Function) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| toArray() | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| allMatch(Predicate) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| lambda$noneMatch$58(Optional) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$allMatch$57(Optional) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$allMatch$56(Predicate, Object) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$asyncMap$6(Throwable) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| anyMatch(Predicate) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| noneMatch(Predicate) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| lambda$toArray$46(IntFunction, List) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$coalesce$32(AtomicReference, IntSupplier) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| lambda$merge$24(AutoCloseable) | | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | |
| buffer() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| buildBuffer() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$reduce$49(BiFunction, PushEvent, Object) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$buildBuffer$21(PushEventConsumer) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| lambda$buffer$20(PushEventConsumer) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| close(PushEvent) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| min(Comparator) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| max(Comparator) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$check$16(AtomicLong, long) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| sorted() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$merge$23(PushEventConsumer, PushEvent) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| findAny() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$limit$12() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$window$35() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$window$34(Duration) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$coalesce$31(int) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$new$0(Object) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 |