Paul Woitaschek
07/03/2020, 1:23 PMfun deSerialize(buffer: BufferedSource): Sequence<Event> {
return generateSequence {
while(true){
if(buffer.request(4)){
break
}
}
val size = buffer.readInt()
while(true){
if(buffer.request(size.toLong())){
break
}
}
val eventBytes = buffer.readByteArray(size.toLong())
protoBuf.load(Event.serializer(), eventBytes)
}
}
Would that be the correct approach to handle this using okio?