cc.otavia.core.channel.message.FixedReadPlanFactory
See theFixedReadPlanFactory companion object
class FixedReadPlanFactory(val bufferSize: Int, maxMessagesPerRead: Int) extends MaxMessagesReadPlanFactory
The ReadPlanFactory that always yields the same buffer size prediction. This handle ignores the feedback from the I/O thread.
Value parameters
- bufferSize
-
size for each read.
- maxMessagesPerRead
-
max message per read.
Attributes
- Companion
- object
- Graph
-
- Supertypes
Members list
In this article