com.qifun.statelessFuture.util.io

SocketInputStream

abstract class SocketInputStream extends PagedInputStream with LimitablePagedInputStream

Linear Supertypes
LimitablePagedInputStream, PagedInputStream, InputStream, Closeable, AutoCloseable, AnyRef, Any
Type Hierarchy Learn more about scaladoc diagrams
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. SocketInputStream
  2. LimitablePagedInputStream
  3. PagedInputStream
  4. InputStream
  5. Closeable
  6. AutoCloseable
  7. AnyRef
  8. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new SocketInputStream()

Abstract Value Members

  1. abstract def readingTimeout: Duration

    Attributes
    protected
  2. abstract val socket: AsynchronousSocketChannel

    Attributes
    protected

Concrete Value Members

  1. final def !=(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  5. final def available(): Int

    Definition Classes
    LimitablePagedInputStream → InputStream
  6. final def available_=(bytesRequired: Int): Stateless[Unit]

    准备bytesRequired字节的数据。

    准备bytesRequired字节的数据。

    returns

    返回的Future成功执行完毕后,available会变为bytesRequired.

    Annotations
    @throws( classOf[EOFException] )
    Example:
    1. (socketInputStream.available = 20).await // 等待20字节的数据

    Exceptions thrown
    java.io.EOFException

    如果对面已经断开连接,会触发本异常

    Note

    available_=返回的Future执行完毕前,如果调用readskip,将导致未定义行为。

  7. final def capacity: Int

    Definition Classes
    LimitablePagedInputStream
  8. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  9. final def close(): Unit

    Close socket.

    Close socket.

    Definition Classes
    SocketInputStream → InputStream → Closeable → AutoCloseable
  10. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  11. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  12. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  13. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  14. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  15. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  16. def mark(arg0: Int): Unit

    Definition Classes
    InputStream
  17. def markSupported(): Boolean

    Definition Classes
    InputStream
  18. def minBufferSizePerRead: Int

    每次读取Socket最少要准备多大的缓冲区

    每次读取Socket最少要准备多大的缓冲区

    Attributes
    protected
  19. final def move(output: Growable[ByteBuffer], length: Long): Long

    Read length bytes data from this SocketInputStream, and append these data to output.

    Read length bytes data from this SocketInputStream, and append these data to output.

    returns

    Number of bytes actually been processed, which may be less than length.

    Definition Classes
    SocketInputStream → PagedInputStream
  20. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  21. final def notify(): Unit

    Definition Classes
    AnyRef
  22. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  23. final def read(b: Array[Byte]): Int

    Definition Classes
    LimitablePagedInputStream → InputStream
  24. final def read(output: Array[Byte], offset: Int, length: Int): Int

    Definition Classes
    LimitablePagedInputStream → InputStream
  25. final def read(): Int

    Definition Classes
    LimitablePagedInputStream → InputStream
  26. def reset(): Unit

    Definition Classes
    InputStream
    Annotations
    @throws( classOf[java.io.IOException] )
  27. final def skip(len: Long): Long

    Definition Classes
    LimitablePagedInputStream → InputStream
  28. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  29. def toString(): String

    Definition Classes
    AnyRef → Any
  30. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  31. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  32. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from LimitablePagedInputStream

Inherited from PagedInputStream

Inherited from InputStream

Inherited from Closeable

Inherited from AutoCloseable

Inherited from AnyRef

Inherited from Any

Ungrouped