otavia
0.4.6-SNAPSHOT
DocsAPI
Generated with
Copyright (c) 2022, Yan Kun/Otavia Project
Copyright (c) 2022, Yan Kun/Otavia Project
otavia/cc.otavia/cc.otavia.core/cc.otavia.core.channel/AbstractUnsafeChannel

AbstractUnsafeChannel

cc.otavia.core.channel.AbstractUnsafeChannel
abstract class AbstractUnsafeChannel(val channel: AbstractChannel) extends UnsafeChannel, ChannelState

The AbstractChannel in Reactor

Attributes

Graph
Supertypes
trait ChannelState
class Object
trait Matchable
class Any
Show all
Known subtypes

Members list

Value members

Concrete methods

protected def clearScheduledRead(): Unit
protected def doClearScheduledRead(): Unit

Clear any previous scheduled read. By default, this method does nothing but implementations might override it to add extra logic.

Clear any previous scheduled read. By default, this method does nothing but implementations might override it to add extra logic.

Attributes

final protected def isAllowHalfClosure: Boolean
def isConnected: Boolean
def setReadPlan(plan: ReadPlan): Unit

Inherited methods

def directAllocator: PooledPageAllocator

Attributes

Inherited from:
UnsafeChannel
final def executorAddress: ActorAddress[_]

Attributes

Inherited from:
UnsafeChannel
final protected def get(mask: Long): Boolean

Attributes

Inherited from:
CompressionBooleanLong
final def getAt(position: Int): Boolean

Attributes

Inherited from:
CompressionBooleanLong
def heapAllocator: PooledPageAllocator

Attributes

Inherited from:
UnsafeChannel
def isActive: Boolean

Return true if the UnsafeChannel is active and so connected.

Return true if the UnsafeChannel is active and so connected.

Attributes

Inherited from:
UnsafeChannel
def isOpen: Boolean

Returns true if the UnsafeChannel is open and may get active later

Returns true if the UnsafeChannel is open and may get active later

Attributes

Inherited from:
UnsafeChannel
def isShutdown(direction: ChannelShutdownDirection): Boolean

Returns true if the ChannelShutdownDirection of the UnsafeChannel was shutdown before.

Returns true if the ChannelShutdownDirection of the UnsafeChannel was shutdown before.

Value parameters

direction

shutdown direction

Attributes

Inherited from:
UnsafeChannel
final protected def set(mask: Long, value: Boolean): Unit

Attributes

Inherited from:
CompressionBooleanLong
final def setAt(position: Int, value: Boolean): Unit

Attributes

Inherited from:
CompressionBooleanLong
protected def toBinaryString(): String

Attributes

Inherited from:
CompressionBooleanLong
def unsafeBind(local: SocketAddress): Unit

Bind the Channel to the SocketAddress

Bind the Channel to the SocketAddress

Value parameters

localAddress

the SocketAddress to bound to.

Attributes

Throws
Exception

when an error happens.

Inherited from:
UnsafeChannel
def unsafeClose(cause: Option[Throwable]): Unit

Close the Channel

Close the Channel

Attributes

Inherited from:
UnsafeChannel
def unsafeConnect(remote: SocketAddress, local: Option[SocketAddress], fastOpen: Boolean): Unit

Attributes

Inherited from:
UnsafeChannel
def unsafeDisconnect(): Unit

Disconnect this Channel from its remote peer

Disconnect this Channel from its remote peer

Attributes

Throws
Exception

thrown on error.

Inherited from:
UnsafeChannel
def unsafeFlush(payload: FileRegion | RecyclablePageBuffer): Unit

Attributes

Inherited from:
UnsafeChannel
def unsafeOpen(path: Path, options: Seq[OpenOption], attrs: Seq[FileAttribute[_]]): Unit

Attributes

Inherited from:
UnsafeChannel
def unsafeRead(readPlan: ReadPlan): Unit

Schedule a read operation.

Schedule a read operation.

Attributes

Throws
Exception

thrown on error.

Inherited from:
UnsafeChannel
def unsafeShutdown(direction: ChannelShutdownDirection): Unit

Shutdown one direction of the Channel.

Shutdown one direction of the Channel.

Value parameters

direction

the direction to shut unsafewn.

Attributes

Throws
Exception

thrown on error.

Inherited from:
UnsafeChannel

Concrete fields

protected var currentReadPlan: ReadPlan
Generated with
Copyright (c) 2022, Yan Kun/Otavia Project
Copyright (c) 2022, Yan Kun/Otavia Project