All Implemented Interfaces:: com.dehnes.kotlinredis.extentions.ElementSink , com.dehnes.kotlinredis.extentions.ScoredElementSink


public final class StreamScoredElementSinkToByteArrays
 implements ScoredElementSink<StreamWithLength>

Nested Classes
Modifier and Type	Class	Description

Fields
Modifier and Type	Field	Description

Constructors
Constructor	Description
`StreamScoredElementSinkToByteArrays(Function1<List<Pair<ByteArray, Double>>, Unit> onResult)`

Enum Constants
Enum Constant	Description

Modifier and Type	Method	Description
`Unit`	`onElement(StreamWithLength value)`
`Unit`	`onScore(Double score)`
`Unit`	`onComplete()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

StreamScoredElementSinkToByteArrays(Function1<List<Pair<ByteArray, Double>>, Unit> onResult)

 Unit onElement(StreamWithLength value)

Class StreamScoredElementSinkToByteArrays