Added AeronWriter size initialization
This commit is contained in:
parent
307b8f558f
commit
5583948961
@ -18,4 +18,4 @@ package dorkbox.network.connection.streaming
|
|||||||
|
|
||||||
import dorkbox.network.serialization.AeronOutput
|
import dorkbox.network.serialization.AeronOutput
|
||||||
|
|
||||||
class AeronWriter: StreamingWriter, AeronOutput()
|
class AeronWriter(size: Int): StreamingWriter, AeronOutput(size)
|
||||||
|
@ -130,7 +130,8 @@ internal class StreamingManager<CONNECTION : Connection>(
|
|||||||
streamingDataInMemory[streamId] = FileWriter(tempFileLocation)
|
streamingDataInMemory[streamId] = FileWriter(tempFileLocation)
|
||||||
} else {
|
} else {
|
||||||
endPoint.logger.info { "Saving streaming data [${streamId}] in memory" }
|
endPoint.logger.info { "Saving streaming data [${streamId}] in memory" }
|
||||||
streamingDataInMemory[streamId] = AeronWriter()
|
// .toInt is safe because we know the total size is < than maxStreamSizeInMemoryInBytes
|
||||||
|
streamingDataInMemory[streamId] = AeronWriter(message.totalSize.toInt())
|
||||||
}
|
}
|
||||||
|
|
||||||
// this must be last
|
// this must be last
|
||||||
|
Loading…
Reference in New Issue
Block a user