DefaultReactiveStreamOperations

Source file "org/springframework/data/redis/core/DefaultReactiveStreamOperations.java" was not found during generation of report.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total579 of 5790%0 of 0n/a585886865858
acknowledge(Object, String, RecordId[])200%n/a115511
add(Record)180%n/a114411
DefaultReactiveStreamOperations(ReactiveRedisTemplate, RedisSerializationContext, HashMapper)170%n/a115511
createGroup(Object, ReadOffset, String)170%n/a114411
range(Object, Range, RedisZSetCommands.Limit)170%n/a114411
read(Consumer, StreamReadOptions, StreamOffset[])170%n/a114411
reverseRange(Object, Range, RedisZSetCommands.Limit)170%n/a114411
rawHashKey(Object)160%n/a113311
rawValue(Object)160%n/a113311
delete(Object, RecordId[])130%n/a113311
deleteConsumer(Object, Consumer)130%n/a113311
destroyGroup(Object, String)130%n/a113311
consumers(Object, String)130%n/a113311
read(StreamReadOptions, StreamOffset[])130%n/a113311
lambda$read$15(StreamOffset[], Consumer, StreamReadOptions, ReactiveStreamCommands)130%n/a112211
pending(Object, String, Range, long)120%n/a112211
pending(Object, Consumer, Range, long)120%n/a112211
deserializeRecordFields(Map.Entry)120%n/a111111
lambda$read$14(StreamOffset[], StreamReadOptions, ReactiveStreamCommands)120%n/a112211
trim(Object, long, boolean)110%n/a112211
lambda$deserializeRecord$22(ByteBufferRecord, MapRecord)110%n/a111111
lambda$reverseRange$16(Object, Range, RedisZSetCommands.Limit, ReactiveStreamCommands)110%n/a111111
lambda$range$13(Object, Range, RedisZSetCommands.Limit, ReactiveStreamCommands)110%n/a111111
pending(Object, String)100%n/a112211
serializeRecordFields(Map.Entry)100%n/a111111
lambda$serializeRecord$23(MapRecord, MapRecord)100%n/a111111
info(Object)90%n/a112211
groups(Object)90%n/a112211
size(Object)90%n/a112211
rawStreamOffsets(StreamOffset[])90%n/a112211
createMono(Function)90%n/a112211
createFlux(Function)90%n/a112211
lambda$createGroup$3(Object, String, ReadOffset, ReactiveStreamCommands)90%n/a111111
lambda$rawStreamOffsets$18(StreamOffset)80%n/a111111
lambda$trim$17(Object, long, boolean, ReactiveStreamCommands)80%n/a111111
lambda$pending$10(ByteBuffer, Consumer, Range, long, ReactiveStreamCommands)80%n/a111111
lambda$pending$9(ByteBuffer, String, Range, long, ReactiveStreamCommands)80%n/a111111
lambda$acknowledge$0(Object, String, RecordId[], ReactiveStreamCommands)80%n/a111111
readHashKey(ByteBuffer)70%n/a111111
serializeRecord(MapRecord)70%n/a112211
lambda$consumers$6(Object, String, ReactiveStreamCommands)70%n/a111111
lambda$destroyGroup$5(Object, String, ReactiveStreamCommands)70%n/a111111
lambda$deleteConsumer$4(Object, Consumer, ReactiveStreamCommands)70%n/a111111
lambda$delete$2(Object, RecordId[], ReactiveStreamCommands)70%n/a111111
trim(Object, long)60%n/a111111
rawKey(Object)60%n/a111111
readKey(ByteBuffer)60%n/a111111
deserializeHashValue(ByteBuffer)60%n/a111111
deserializeRecord(ByteBufferRecord)60%n/a111111
lambda$createFlux$21(Function, ReactiveRedisConnection)60%n/a111111
lambda$createMono$20(Function, ReactiveRedisConnection)60%n/a111111
lambda$size$12(Object, ReactiveStreamCommands)60%n/a111111
lambda$groups$8(Object, ReactiveStreamCommands)60%n/a111111
lambda$info$7(Object, ReactiveStreamCommands)60%n/a111111
lambda$add$1(MapRecord, ReactiveStreamCommands)60%n/a111111
getHashMapper(Class)50%n/a111111
lambda$pending$11(ByteBuffer, String, ReactiveStreamCommands)50%n/a111111
lambda$rawStreamOffsets$19(int)30%n/a111111