From da485055a3d7eabb6eb10e0ddceda1d19b23f311 Mon Sep 17 00:00:00 2001 From: Johannes Rudolph Date: Wed, 8 Jul 2015 14:40:16 +0200 Subject: [PATCH] +htc add java-side constructors for ChunkStreamParts --- .../http/javadsl/model/ChunkStreamPart.java | 28 +++++++++++++++++++ 1 file changed, 28 insertions(+) diff --git a/akka-http-core/src/main/java/akka/http/javadsl/model/ChunkStreamPart.java b/akka-http-core/src/main/java/akka/http/javadsl/model/ChunkStreamPart.java index 0593af6e56..6a2c5c60d8 100644 --- a/akka-http-core/src/main/java/akka/http/javadsl/model/ChunkStreamPart.java +++ b/akka-http-core/src/main/java/akka/http/javadsl/model/ChunkStreamPart.java @@ -4,6 +4,8 @@ package akka.http.javadsl.model; +import akka.http.impl.util.Util; +import akka.http.scaladsl.model.HttpEntity; import akka.util.ByteString; /** @@ -31,4 +33,30 @@ public abstract class ChunkStreamPart { * it will be empty. */ public abstract Iterable getTrailerHeaders(); + + /** + * Creates a chunk from data and extension. + */ + public static ChunkStreamPart create(ByteString data, String extension) { + return new HttpEntity.Chunk(data, extension); + } + + /** + * Creates a chunk from data with an empty extension. + */ + public static ChunkStreamPart create(ByteString data) { + return create(data, ""); + } + + /** + * The default last ChunkStreamPart that has no extension and no trailer headers. + */ + public static final ChunkStreamPart LAST = HttpEntity.LastChunk$.MODULE$; + + /** + * Creates a last chunk with extension and headers. + */ + public static ChunkStreamPart createLast(String extension, Iterable trailerHeaders){ + return new HttpEntity.LastChunk(extension, Util.convertIterable(trailerHeaders)); + } }