cc.otavia.core.channel.message

Members list

Type members

Classlikes

A AdaptiveBufferMessage only notice AdaptiveBuffer is change.

A AdaptiveBufferMessage only notice AdaptiveBuffer is change.

Attributes

Supertypes
class Object
trait Matchable
class Any
Self type

AdaptiveBufferMessage is a message send between ChannelHandler which ChannelHandler.isBufferHandler is true.

AdaptiveBufferMessage is a message send between ChannelHandler which ChannelHandler.isBufferHandler is true.

Attributes

Supertypes
class Object
trait Matchable
class Any
Known subtypes
case class AdaptiveBufferRange(start: Int, length: Int) extends AdaptiveBufferMessage

A AdaptiveBufferMessage use for describe a data range in AdaptiveBuffer

A AdaptiveBufferMessage use for describe a data range in AdaptiveBuffer

Value parameters

length

data length in AdaptiveBuffer

start

data start offset in AdaptiveBuffer

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all
object AutoReadPlan extends ReadPlan

Attributes

Supertypes
trait ReadPlan
class Object
trait Matchable
class Any
Self type
case class DatagramAdaptiveRangePacket(start: Int, length: Int, recipient: SocketAddress, sender: Option[SocketAddress]) extends AdaptiveBufferMessage

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all
case class FileReadPlan(length: Int, position: Long) extends ReadPlan

Read file channel from position with length, See also FileChannel.

Read file channel from position with length, See also FileChannel.

Value parameters

length

Length of bytes want to read. If length is -1, read until file end.

position

If position is -1, bytes are read starting at this channel's current file position, and then the file position is updated with the number of bytes actually read. If position is not -1, then read starting at the given file position rather than at the channel's current position. This method does not modify this channel's position. If the given position is greater than the file's current size then no bytes are read.

Attributes

Supertypes
trait Serializable
trait Product
trait Equals
trait ReadPlan
class Object
trait Matchable
class Any
Show all
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.

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
Supertypes
class Object
trait Matchable
class Any

Attributes

Companion
class
Supertypes
class Object
trait Matchable
class Any
Self type
abstract class MaxMessagesReadPlanFactory(maxMessagesPerRead: Int) extends ReadPlanFactory

Base implementation of ReadPlanFactory which allows to limit the number of messages read per read loop.

Base implementation of ReadPlanFactory which allows to limit the number of messages read per read loop.

Attributes

Companion
object
Supertypes
class Object
trait Matchable
class Any
Known subtypes

Attributes

Companion
class
Supertypes
class Object
trait Matchable
class Any
Self type
trait ReadPlan

ReadPlan is a trait usage by ChannelOutboundInvoker.read to describe how to read data read from a channel

ReadPlan is a trait usage by ChannelOutboundInvoker.read to describe how to read data read from a channel

Attributes

Supertypes
class Object
trait Matchable
class Any
Known subtypes

Implementations allow to influence how much data / messages are read per read loop invocation.

Implementations allow to influence how much data / messages are read per read loop invocation.

Attributes

Supertypes
class Object
trait Matchable
class Any
Known subtypes