Now fixed streaming message data when finished
This commit is contained in:
parent
f0f7a5eba1
commit
b8acc6b2c0
@ -83,7 +83,7 @@ internal class StreamingManager<CONNECTION : Connection>(private val logger: KLo
|
|||||||
|
|
||||||
try {
|
try {
|
||||||
val input = AeronInput(output.internalBuffer)
|
val input = AeronInput(output.internalBuffer)
|
||||||
val streamedMessage = kryo.readClassAndObject(input)
|
val streamedMessage = kryo.read(input)
|
||||||
|
|
||||||
// NOTE: This MUST be on a new co-routine
|
// NOTE: This MUST be on a new co-routine
|
||||||
actionDispatch.launch {
|
actionDispatch.launch {
|
||||||
|
Loading…
Reference in New Issue
Block a user