DefaultKafkaReceiver

Source file "reactor/kafka/receiver/internals/DefaultKafkaReceiver.java" was not found during generation of report.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total319 of 3190%16 of 160%404063633232
lambda$null$14(TransactionManager, ConsumerHandler, ConsumerRecords)470%20%22121211
lambda$withHandler$17(AckMode)170%n/a112211
lambda$receiveExactlyOnce$15(TransactionManager, Integer, Scheduler, ConsumerHandler)170%n/a115511
lambda$receive$3(Integer, Scheduler, ConsumerHandler)160%n/a116611
lambda$null$5(ConsumerRecords, ConsumerHandler)150%20%224411
doOnConsumer(Function)140%20%223311
lambda$receiveAutoAck$7(Integer, Scheduler, ConsumerHandler)130%n/a115511
DefaultKafkaReceiver(ConsumerFactory, ReceiverOptions)120%n/a115511
lambda$new$0(Throwable)120%40%332211
withHandler(AckMode, BiFunction)110%n/a112211
lambda$receiveAtmostOnce$10(Integer, Scheduler, ConsumerHandler)100%n/a114411
lambda$null$9(ConsumerHandler, Scheduler, ConsumerRecords)90%n/a114411
receiveExactlyOnce(TransactionManager, Integer)80%n/a111111
lambda$withHandler$20(BiFunction, ConsumerHandler)80%n/a111111
lambda$null$12(ConsumerHandler, ConsumerRecords)80%n/a112211
lambda$null$2(ConsumerHandler, ConsumerRecord)80%n/a112211
receive(Integer)70%n/a111111
receiveAutoAck(Integer)70%n/a111111
receiveAtmostOnce(Integer)70%n/a111111
preparePublishOnQueueSize(Integer)70%20%221111
lambda$null$18()70%n/a111111
lambda$null$11(ConsumerRecords)70%20%221111
lambda$null$6(ConsumerHandler, ConsumerRecords)70%n/a112211
lambda$null$4(ConsumerRecords)70%20%221111
lambda$withHandler$22(ConsumerHandler)60%n/a111111
lambda$null$19(BiFunction, ConsumerHandler, Scheduler)60%n/a111111
lambda$null$8(ConsumerHandler, ConsumerRecord)60%n/a111111
lambda$null$16(Throwable)50%n/a111111
lambda$null$13(ConsumerHandler)50%n/a111111
lambda$null$21(SignalType)40%n/a111111
static {...}40%n/a111111
lambda$null$1(ConsumerRecords)20%n/a111111