AmqpReceiveLinkProcessor

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,182 of 1,1820%130 of 1300%97973303303232
drainQueue()1410%300%1616393911
onNext(AmqpReceiveLink)1280%40%33323211
addCreditsToLink(String)930%60%44282811
subscribe(CoreSubscriber)840%180%1010212111
AmqpReceiveLinkProcessor(String, int, Disposable)790%20%22171711
onError(Throwable)780%80%55212111
requestUpstream()560%80%55171711
lambda$onNext$6(String, Throwable)550%120%77171711
lambda$onNext$7(String)540%60%44171711
getCreditsToAdd()400%60%449911
lambda$onNext$0(String, AmqpReceiveLink)400%20%22111111
lambda$onNext$2(String, AmqpReceiveLink, AmqpEndpointState)390%n/a11111111
request(long)330%20%227711
checkAndSetTerminated()300%40%33101011
disposeReceiver(AmqpReceiveLink)290%20%22101011
onSubscribe(Subscription)240%20%226611
onDispose()230%20%227711
lambda$onNext$5(String, AmqpReceiveLink, AmqpEndpointState)210%20%227711
dispose()200%20%228811
drain()190%40%337711
lambda$addCreditsToLink$10(String, Throwable)190%n/a116611
onComplete()140%n/a115511
isTerminated()110%40%331111
cancel()100%20%225511
static {...}100%n/a114411
lambda$onNext$4(String, Throwable)90%n/a111111
lambda$onNext$8(Message)80%n/a113311
lambda$onNext$1(AmqpEndpointState)70%20%221111
getError()30%n/a111111
getPrefetch()30%n/a111111
lambda$addCreditsToLink$9(Void)0%n/a111111
lambda$onNext$3(Void)0%n/a111111