Package org.apache.pekko.http.impl.util

Class ByteStringOutputStream

java.lang.Object

java.io.OutputStream

java.io.ByteArrayOutputStream

org.apache.pekko.http.impl.util.ByteStringOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

public final class ByteStringOutputStream
extends ByteArrayOutputStream

INTERNAL API

An OutputStream that buffers into a byte array like ByteArrayOutputStream but that can hand the buffered data over as a pekko.util.ByteString without copying it, unlike ByteArrayOutputStream.toByteArray which always creates a copy.

Derived from the ByteStringOutputStream in Apache Pekko gRPC (https://github.com/apache/pekko-grpc/pull/862).

Field Summary

Fields inherited from class java.io.ByteArrayOutputStream

buf, count

Constructor Summary

Constructors

Constructor	Description
ByteStringOutputStream(int capacity)

Method Summary

Modifier and Type	Method	Description
org.apache.pekko.util.ByteString	toByteStringUnsafe()	Wraps the bytes written so far in a ByteString.

Methods inherited from class java.io.ByteArrayOutputStream

close, reset, size, toByteArray, toString, toString, toString, toString, write, write, writeBytes, writeTo

Methods inherited from class java.io.OutputStream

flush, nullOutputStream, write

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

ByteStringOutputStream

public ByteStringOutputStream(int capacity)

Method Details

toByteStringUnsafe

public org.apache.pekko.util.ByteString toByteStringUnsafe()

Wraps the bytes written so far in a ByteString. The buffer may be shared with the returned ByteString, so this stream must not be written to, reset or reused afterwards.

Returns:

(undocumented)