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

+htp add shortcuts for quick encoding / decoding

Browse source
This commit is contained in:
Johannes Rudolph 2014-11-27 18:11:40 +01:00
parent 0b1dd68eaf
commit 2a37831937
4 changed files with 8 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-http-tests/src/test/scala/akka/http/coding/DeflateSpec.scala
View file

@ -65,8 +65,8 @@ class DeflateSpec extends WordSpec with CodecSpecSupport {
}
}
def ourDeflate(bytes: ByteString): ByteString = Deflate.newCompressor.compressAndFinish(bytes)
def ourInflate(bytes: ByteString): ByteString = Deflate.newDecompressor.decompress(bytes)
def ourDeflate(bytes: ByteString): ByteString = Deflate.encode(bytes)
def ourInflate(bytes: ByteString): ByteString = Deflate.decode(bytes)
def streamDeflate(bytes: ByteString) = {
val output = new ByteArrayOutputStream()

4
akka-http-tests/src/test/scala/akka/http/coding/GzipSpec.scala
View file

@ -103,8 +103,8 @@ class GzipSpec extends WordSpec with CodecSpecSupport {
}
def gzip(s: String) = ourGzip(ByteString(s, "UTF8"))
def ourGzip(bytes: ByteString): ByteString = Gzip.newCompressor.compressAndFinish(bytes)
def ourGunzip(bytes: ByteString): ByteString = Gzip.newDecompressor.decompressAndFinish(bytes)
def ourGzip(bytes: ByteString): ByteString = Gzip.encode(bytes)
def ourGunzip(bytes: ByteString): ByteString = Gzip.decode(bytes)
lazy val corruptGzipContent = {
val content = gzip("Hello").toArray

2
akka-http/src/main/scala/akka/http/coding/Decoder.scala
View file

@ -21,6 +21,8 @@ trait Decoder {
def decodeData[T](t: T)(implicit mapper: DataMapper[T]): T =
mapper.transformDataBytes(t, newDecodeTransfomer)
def decode(input: ByteString): ByteString = newDecompressor.decompressAndFinish(input)
def newDecompressor: Decompressor
def newDecodeTransfomer(): Flow[ByteString, ByteString] = {

3
akka-http/src/main/scala/akka/http/coding/Encoder.scala
View file

@ -4,7 +4,6 @@
package akka.http.coding
import java.io.ByteArrayOutputStream
import akka.http.model._
import akka.http.util.StreamUtils
import akka.util.ByteString
@ -24,6 +23,8 @@ trait Encoder {
def encodeData[T](t: T)(implicit mapper: DataMapper[T]): T =
mapper.transformDataBytes(t, newEncodeTransformer)
def encode(input: ByteString): ByteString = newCompressor.compressAndFinish(input)
def newCompressor: Compressor
def newEncodeTransformer(): Flow[ByteString, ByteString] = {