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.  def channel: java.nio.channels.SocketChannel

   Attributes

   protected[channels]

   Definition Classes

   Ops → ScatteringByteOps → GatheringByteOps

6.  def clone(): AnyRef

   Attributes

   protected[lang]

   Definition Classes

   AnyRef

   Annotations

   @throws(classOf[java.lang.CloneNotSupportedException]) @native()

7.  final def eq(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

8.  def equals(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef → Any

9.  def finalize(): Unit

   Attributes

   protected[lang]

   Definition Classes

   AnyRef

   Annotations

   @throws(classOf[java.lang.Throwable])

10.  final def getClass(): Class[_ <: AnyRef]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

11.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

12.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

13.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

14.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

15.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

16.  final def read(dst: ByteBuffer)(implicit trace: Trace): IO[IOException, Int]

    Reads a sequence of bytes from this channel into the given buffer.

    Reads a sequence of bytes from this channel into the given buffer.

    Fails with java.io.EOFException if end-of-stream is reached.

    returns

    The number of bytes read, possibly 0

    Definition Classes

    ScatteringByteOps

17.  final def read(dsts: Seq[ByteBuffer])(implicit trace: Trace): IO[IOException, Long]

    Reads a sequence of bytes from this channel into the provided list of buffers, in order.

    Reads a sequence of bytes from this channel into the provided list of buffers, in order.

    Fails with java.io.EOFException if end-of-stream is reached.

    returns

    The number of bytes read in total, possibly 0

    Definition Classes

    ScatteringByteOps

18.  final def readChunk(capacity: Int)(implicit trace: Trace): IO[IOException, Chunk[Byte]]

    Reads a chunk of bytes.

    Reads a chunk of bytes.

    Fails with java.io.EOFException if end-of-stream is reached.

    capacity

    The maximum number of bytes to be read.

    returns

    The bytes read, between 0 and capacity in size, inclusive

    Definition Classes

    ScatteringByteOps

19.  final def readChunks(capacities: Seq[Int])(implicit trace: Trace): IO[IOException, List[Chunk[Byte]]]

    Reads a sequence of bytes grouped into multiple chunks.

    Reads a sequence of bytes grouped into multiple chunks.

    Fails with java.io.EOFException if end-of-stream is reached.

    capacities

    For each int in this sequence, a chunk of that size is produced, if there is enough data in the channel.

    returns

    A list with one Chunk per input size. Some chunks may be less than the requested size if the channel does not have enough data

    Definition Classes

    ScatteringByteOps

20.  def sink(bufferConstruct: UIO[ByteBuffer])(implicit trace: Trace): ZSink[Any, IOException, Byte, Byte, Long]

    A sink that will write all the bytes it receives to this channel.

    A sink that will write all the bytes it receives to this channel. The sink's result is the number of bytes written. Note: This method does not work well with a channel in non-blocking mode, as it will busy-wait whenever the channel is not ready for writes. The returned sink should be run within the context of a useBlocking call for correct blocking and interruption support.

    bufferConstruct

    Optional, overrides how to construct the buffer used to transfer bytes received by the sink to this channel. By default a heap buffer is used, but a direct buffer will usually perform better.

    Definition Classes

    GatheringByteOps

21.  def sink()(implicit trace: Trace): ZSink[Any, IOException, Byte, Byte, Long]

    Definition Classes

    GatheringByteOps

22.  def stream(bufferConstruct: UIO[ByteBuffer])(implicit trace: Trace): Stream[IOException, Byte]

    A ZStream that reads from this channel.

    A ZStream that reads from this channel. Note: This method does not work well with a channel in non-blocking mode, as it will busy-wait whenever the channel is not ready for reads. The returned stream should be run within the context of a useBlocking call for correct blocking and interruption support.

    The stream terminates without error if the channel reaches end-of-stream.

    bufferConstruct

    Optional, overrides how to construct the buffer used to transfer bytes read from this channel into the stream. By default a heap buffer is used, but a direct buffer will usually perform better.

    Definition Classes

    ScatteringByteOps

23.  def stream()(implicit trace: Trace): Stream[IOException, Byte]

    Definition Classes

    ScatteringByteOps

24.  final def synchronized[T0](arg0: => T0): T0

    Definition Classes

    AnyRef

25.  def toString(): String

    Definition Classes

    AnyRef → Any

26.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException])

27.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException])

28.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException]) @native()

29.  final def write(src: ByteBuffer)(implicit trace: Trace): IO[IOException, Int]

    Definition Classes

    GatheringByteOps

30.  final def write(srcs: List[ByteBuffer])(implicit trace: Trace): IO[IOException, Long]

    Definition Classes

    GatheringByteOps

31.  final def writeChunk(src: Chunk[Byte])(implicit trace: Trace): IO[IOException, Unit]

    Writes a chunk of bytes.

    Writes a chunk of bytes.

    Multiple writes may be performed to write the entire chunk.

    Definition Classes

    GatheringByteOps

32.  final def writeChunks(srcs: List[Chunk[Byte]])(implicit trace: Trace): IO[IOException, Unit]

    Writes a list of chunks, in order.

    Writes a list of chunks, in order.

    Multiple writes may be performed in order to write all the chunks.

    Definition Classes

    GatheringByteOps