com.qifun.statelessFuture.util

io

package io

Visibility
  1. Public
  2. All

Type Members

  1. final case class Nio2Future[A](underlying: (CompletionHandler[A, Null]) ⇒ Unit) extends AnyVal with Stateless[A] with Product with Serializable

  2. abstract class SocketInputStream extends PagedInputStream with LimitablePagedInputStream

  3. trait SocketWritingQueue extends AnyRef

    写入Socket的缓冲数据队列。

    写入Socket的缓冲数据队列。

    Note

    SocketWritingQueue保证线程安全,允许多个线程向这里提交要写入的数据。 enqueue提交的缓冲区将按提交顺序排队写入,而不会混合。

Value Members

  1. object Nio2Future extends Serializable

Ungrouped