StreamManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total42 of 41189%4 of 2080%7441099334
putStreamingState(StreamingState)72477%1150%121701
putInitiatorStream(StreamResultFuture)71263%1150%120301
putFollowerStream(StreamResultFuture)71263%1150%120301
removeNotificationListener(NotificationListener, NotificationFilter, Object)70%n/a112211
notifySafeOnRegister(StreamResultFuture)51777%2100%022701
removeNotificationListener(NotificationListener)50%n/a112211
setStreamingSlowEventsLogTimeout(String)30%n/a112211
addStreamingStateAgain(StreamingState)1990%1150%121401
StreamManager()55100%n/a0101501
getTotalRemainingOngoingBytes()42100%4100%030601
registerFollower(StreamResultFuture)26100%2100%020701
registerInitiator(StreamResultFuture)20100%n/a010501
findSession(InetAddressAndPort, TimeUUID, int, boolean)15100%2100%020201
getCurrentStreams()14100%n/a010101
findSession(Map, InetAddressAndPort, TimeUUID, int)14100%2100%020401
getRateLimiter(InetAddressAndPort)9100%n/a010301
getEntireSSTableRateLimiter(InetAddressAndPort)9100%n/a010301
static {...}8100%n/a010201
addNotificationListener(NotificationListener, NotificationFilter, Object)7100%n/a010201
lambda$registerFollower$1(StreamResultFuture)7100%n/a010101
lambda$registerInitiator$0(StreamResultFuture)7100%n/a010101
getStreamingState(TimeUUID)6100%n/a010101
addListener(StreamManager.StreamListener)6100%n/a010201
removeListener(StreamManager.StreamListener)6100%n/a010201
getReceivingStream(TimeUUID)6100%n/a010101
getInitiatorStream(TimeUUID)6100%n/a010101
start()5100%n/a010201
stop()5100%n/a010201
getStreamingStates()5100%n/a010101
clearStates()5100%n/a010201
getNotificationInfo()4100%n/a010101
setStreamingStatsEnabled(boolean)3100%n/a010201
getStreamingSlowEventsLogTimeout()3100%n/a010101
getStreamingStatsEnabled()2100%n/a010101