raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Removed object ByteStringBuilder

Browse source 
* ByteStringBuilder.apply was unusual for Scala Builders
* Moved OutputStreamWrapper implementation into ByteStringBuilder
This commit is contained in:
Oliver Schulz 2012-05-26 12:59:48 +02:00
parent b54e9ba78e
commit 93d5e440ea
1 changed files with 9 additions and 19 deletions
Download patch file Download diff file Expand all files Collapse all files

28
akka-actor/src/main/scala/akka/util/ByteString.scala
View file

@ -435,25 +435,14 @@ sealed abstract class CompactByteString extends ByteString with Serializable {
def compact: this.type = this
}
object ByteStringBuilder {
def apply(initialSize: Int = 0): ByteStringBuilder = new ByteStringBuilder(initialSize)
/**
* An OutputStream that directly wraps a ByteStringBuilder.
*/
class OutputStreamWrapper(val builder: ByteStringBuilder) extends java.io.OutputStream {
def write(b: Int): Unit = builder += b.toByte
override def write(b: Array[Byte], off: Int, len: Int): Unit = { builder.putBytes(b, off, len) }
}
}
/**
* A mutable builder for efficiently creating a [[akka.util.ByteString]].
*
* The created ByteString is not automatically compacted.
*/
final class ByteStringBuilder extends Builder[Byte, ByteString] {
builder ⇒
import ByteString.{ ByteString1C, ByteString1, ByteStrings }
private var _length: Int = 0
private val _builder: VectorBuilder[ByteString1] = new VectorBuilder[ByteString1]()
@ -478,11 +467,6 @@ final class ByteStringBuilder extends Builder[Byte, ByteString] {
}
}
def this(initialSize: Int) = {
this()
if (initialSize > 0) sizeHint(initialSize)
}
def length: Int = _length
override def sizeHint(len: Int): Unit = {
@ -719,9 +703,15 @@ final class ByteStringBuilder extends Builder[Byte, ByteString] {
ByteStrings(bytestrings, _length)
}
private val outputStreamWrapper: java.io.OutputStream = new java.io.OutputStream {
def write(b: Int): Unit = builder += b.toByte
override def write(b: Array[Byte], off: Int, len: Int): Unit = { builder.putBytes(b, off, len) }
}
/**
* Directly wraps this ByteStringBuilder in an OutputStream. Write
* operations on the stream are forwarded to the builder.
*/
def asOutputStream: java.io.OutputStream = new ByteStringBuilder.OutputStreamWrapper(this)
def asOutputStream: java.io.OutputStream = outputStreamWrapper
}