class ReadableByteChannelWrapper[T] extends ReadableByteChannelWrapperBase[T]
Wraps a ReadableByteChannel to provide DataChunks, optionally closes the channel (defaults to closing).
Can work with either direct or heap based buffers and uses pools to re-use the allocated buffers.
- Alphabetic
- By Inheritance
- ReadableByteChannelWrapper
- ReadableByteChannelWrapperBase
- DataChunker
- CloseOnNeed
- IsClosed
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new ReadableByteChannelWrapper(channel: ReadableByteChannel, closeChannel: Boolean = true, bytePool: Pool[ByteBuffer] = DefaultBufferPool, directBufferArrayPool: Pool[Array[Byte]] = DefaultByteArrayPool)(implicit ev: DataChunkEvidence[T])
- directBufferArrayPool
is used when there is a direct ByteBuffer only.
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- def ++(close2: CloseOnNeed): CloseOnNeed
- Definition Classes
- CloseOnNeed
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- val backingArray: Array[Byte]
- Attributes
- protected
- Definition Classes
- ReadableByteChannelWrapper → ReadableByteChannelWrapperBase
- val buffer: ByteBuffer
- Attributes
- protected
- Definition Classes
- ReadableByteChannelWrapper → ReadableByteChannelWrapperBase
- val channel: ReadableByteChannel
- Definition Classes
- ReadableByteChannelWrapperBase
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- val closeChannel: Boolean
- Definition Classes
- ReadableByteChannelWrapperBase
- def closeResource: Unit
Close the underlying something, but only do it once.
Close the underlying something, but only do it once.
This allows closing of an xml input stream directly after the end doc, but without disturbing the normal model.
- Definition Classes
- CloseOnNeed
- def direct(): DataChunk
Called when processing via Direct Buffers
Called when processing via Direct Buffers
- Attributes
- protected
- Definition Classes
- ReadableByteChannelWrapperBase
- def doClose: Unit
Closes the channel when closeChannel is true - ensure to call from derived classes
Closes the channel when closeChannel is true - ensure to call from derived classes
- Attributes
- protected
- Definition Classes
- ReadableByteChannelWrapper → ReadableByteChannelWrapperBase → CloseOnNeed
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- implicit val ev: DataChunkEvidence[T]
- Definition Classes
- ReadableByteChannelWrapperBase → DataChunker
- 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()
- def isClosed: Boolean
- Definition Classes
- CloseOnNeed → IsClosed
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def jbytes(): DataChunk
Called when processing array backed buffers
Called when processing array backed buffers
- Attributes
- protected
- Definition Classes
- ReadableByteChannelWrapperBase
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def nextChunk: DataChunk
Receives the next chunk from the underlying
Receives the next chunk from the underlying
- Definition Classes
- ReadableByteChannelWrapperBase → DataChunker
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def underlyingClosed: Boolean
Is the underlying resource closed - if true the dataChunkEnumerator will return the Iteratee passed to it, stopping evaluation
Is the underlying resource closed - if true the dataChunkEnumerator will return the Iteratee passed to it, stopping evaluation
- Definition Classes
- ReadableByteChannelWrapperBase → DataChunker
- 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()