DefaultKafkaSender

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

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total402 of 4020%26 of 260%383878782525
DefaultKafkaSender(ProducerFactory, SenderOptions)760%60%44141411
lambda$new$0(ProducerFactory)340%40%339911
sendTransactionally(Publisher)280%n/a117711
static {...}280%n/a112211
lambda$producerProxy$12(Producer, Object, Method, Object[])260%20%225511
close()250%40%338811
transaction(Publisher, Sinks.Many)240%n/a117711
producerProxy(Producer)240%20%226611
lambda$new$1(Mono)190%40%332211
lambda$close$9(Producer)170%20%224411
doSend(Publisher)160%n/a114411
transactionManager()110%20%223311
lambda$doSend$3(Publisher, Producer)110%n/a113311
doOnProducer(Function)70%n/a111111
lambda$transaction$11(Throwable)70%n/a111111
lambda$null$2(Producer, Flux)70%n/a111111
lambda$doOnProducer$8(Function, Producer)60%n/a111111
createOutbound()50%n/a111111
lambda$transaction$10(Sinks.Many)50%n/a111111
lambda$sendTransactionally$5(Sinks.Many, Publisher)50%n/a111111
lambda$doSend$4(Throwable)50%n/a111111
send(Publisher)40%n/a111111
onEmitFailure(SignalType, Sinks.EmitResult)40%n/a111111
lambda$sendTransactionally$7(Sinks.Many)40%n/a111111
lambda$sendTransactionally$6(Sinks.Many)40%n/a111111