trait ScatteringByteOps extends AnyRef
A channel that can read bytes into a sequence of buffers.
- Alphabetic
- By Inheritance
- ScatteringByteOps
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def channel: ScatteringByteChannel
- Attributes
- protected[channels]
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- 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.EOFExceptionif end-of-stream is reached.- returns
The number of bytes read, possibly 0
- 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.EOFExceptionif end-of-stream is reached.- returns
The number of bytes read in total, possibly 0
- 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.EOFExceptionif end-of-stream is reached.- capacity
The maximum number of bytes to be read.
- returns
The bytes read, between 0 and
capacityin size, inclusive
- 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.EOFExceptionif 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
Chunkper input size. Some chunks may be less than the requested size if the channel does not have enough data
- def stream(bufferConstruct: UIO[ByteBuffer])(implicit trace: Trace): Stream[IOException, Byte]
A
ZStreamthat reads from this channel.A
ZStreamthat 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 auseBlockingcall 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.
- def stream()(implicit trace: Trace): Stream[IOException, Byte]
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()