package io
- Alphabetic
- Public
- Protected
Type Members
- case class AppendableWriter(out: Appendable) extends Writer with Product with Serializable
To provide a writer to LSSerializer (and anything else that wants it _) we need to wrap appendables.
- class ByteArrayPool extends SimpleUnboundedPool[Array[Byte]]
Pools byte arrays
- final case class Chunk(array: Array[Byte], offset: Int, length: Int) extends DataChunk with Product with Serializable
A section of a Byte array.
- sealed trait DataChunk extends AnyRef
Represents a chunk of data to feed into an async parser.
Represents a chunk of data to feed into an async parser. The instance is deemed "owned" by the asnyc parser until it requires more input.
- sealed trait DataChunkEvidence[T] extends AnyRef
- trait DataChunker[T] extends CloseOnNeed
An abstraction over a stream that provides DataChunks
- class DirectBufferPool extends SimpleUnboundedPool[ByteBuffer]
ByteBuffer.allocateDirect(bufferSize) backed pool
ByteBuffer.allocateDirect(bufferSize) backed pool
8k default buffer size with a pool reduction of 30
- final case class FullChunk(array: Array[Byte]) extends DataChunk with Product with Serializable
Represents the full array
- class JVMBufferPool extends SimpleUnboundedPool[ByteBuffer]
ByteBuffer.allocate(bufferSize) backed pool
ByteBuffer.allocate(bufferSize) backed pool
8k default buffer size with a pool reduction of 30.
- case class ProxiedCloseOnNeedInputStream(orig: InputStream) extends InputStream with CloseOnNeed with Product with Serializable
Wrap the InputStream to allow better bracketing etc.
- case class ProxiedCloseOnNeedReader(orig: Reader) extends Reader with CloseOnNeed with Product with Serializable
Wrap the Reader to allow better bracketing etc.
- class RBCImplicitWrapper extends AnyRef
Convenience function for wrapping a channel
- class ReadableByteChannelWrapper[T] extends ReadableByteChannelWrapperBase[T]
Wraps a ReadableByteChannel to provide DataChunks, optionally closes the channel (defaults to closing).
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.
- class ReadableByteChannelWrapperBase[T] extends DataChunker[T] with CloseOnNeed
Wraps a ReadableByteChannel to provide DataChunks, optionally closes the channel (defaults to closing).
Wraps a ReadableByteChannel to provide DataChunks, optionally closes the channel (defaults to closing).
This base implementation should only be used against already provided buffers, prefer using ReadableByteChannelWrapper directly instead.
- trait ReadableByteChannelWrapperImplicits extends AnyRef
Value Members
- object DataChunkEvidence
- object DefaultBufferPool extends JVMBufferPool
Default buffer pool backed by byte arrays
- object DefaultByteArrayPool extends ByteArrayPool
Default Byte Array pool with 8k chunks
- object EOFData extends DataChunk
Represents the end of a stream, no more Bytes are available
- object EmptyData extends DataChunk
Represents a data stream with no immediate data to return.
- object ReadableByteChannelWrapper
- object ScalesUtilsIO extends ReadableByteChannelWrapperImplicits