io.zeebe.util

Class StreamUtil

java.lang.Object

io.zeebe.util.StreamUtil

public class StreamUtil
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	DEFAULT_BUFFER_SIZE

Constructor Summary

Constructors

Constructor and Description
StreamUtil()

Method Summary

Modifier and Type	Method and Description
static int	copy(InputStream input, OutputStream output)
static String	digestAsHex(MessageDigest messageDigest)
static MessageDigest	getDigest(String algorithm)
static MessageDigest	getSha1Digest()
static byte[]	read(InputStream input)
static int	read(InputStream input, byte[] dst)
static int	read(InputStream input, byte[] dst, int offset)
static int	read(InputStream input, org.agrona.MutableDirectBuffer buffer, int offset)
static long	readLong(InputStream inputStream)
static String	sha1Hex(InputStream data)
static MessageDigest	updateDigest(MessageDigest messageDigest, InputStream data)
static void	write(org.agrona.DirectBuffer source, OutputStream destination) Writes the DirectBuffer.capacity() bytes given buffer to the destination output.
static void	write(org.agrona.DirectBuffer source, OutputStream destination, int offset, int length) Writes length bytes from source buffer, starting at the given offset, into the given destination.
static void	write(File file, InputStream data, MessageDigest messageDigest)
static void	write(File file, String data)
static void	writeLong(OutputStream outputStream, long longValue)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_BUFFER_SIZE

protected static final int DEFAULT_BUFFER_SIZE

See Also:

Constant Field Values

Constructor Detail

StreamUtil

public StreamUtil()

Method Detail

getDigest

public static MessageDigest getDigest(String algorithm)

getSha1Digest

public static MessageDigest getSha1Digest()

updateDigest

public static MessageDigest updateDigest(MessageDigest messageDigest,
                                         InputStream data)
                                  throws IOException

Throws:

IOException

sha1Hex

public static String sha1Hex(InputStream data)
                      throws IOException

Throws:

IOException

digestAsHex

public static String digestAsHex(MessageDigest messageDigest)

copy

public static int copy(InputStream input,
                       OutputStream output)
                throws IOException

Throws:

IOException

write

public static void write(File file,
                         String data)
                  throws IOException

Throws:

IOException

write

public static void write(File file,
                         InputStream data,
                         MessageDigest messageDigest)
                  throws IOException

Throws:

IOException

read

public static int read(InputStream input,
                       byte[] dst)
                throws IOException

Throws:

IOException

read

public static int read(InputStream input,
                       org.agrona.MutableDirectBuffer buffer,
                       int offset)
                throws IOException

Throws:

IOException

read

public static int read(InputStream input,
                       byte[] dst,
                       int offset)
                throws IOException

Throws:

IOException

read

public static byte[] read(InputStream input)
                   throws IOException

Throws:

IOException

write

public static void write(org.agrona.DirectBuffer source,
                         OutputStream destination)
                  throws IOException

Writes the DirectBuffer.capacity() bytes given buffer to the destination output.

Parameters:

source - buffer to write

destination - output to write to

Throws:

IOException

write

public static void write(org.agrona.DirectBuffer source,
                         OutputStream destination,
                         int offset,
                         int length)
                  throws IOException

Writes length bytes from source buffer, starting at the given offset, into the given destination.

Parameters:

source - buffer to write

destination - output to write to

offset - offset at which to start writing from buffer

length - number of bytes to write

Throws:

IOException

writeLong

public static void writeLong(OutputStream outputStream,
                             long longValue)
                      throws IOException

Throws:

IOException

readLong

public static long readLong(InputStream inputStream)
                     throws IOException

Throws:

IOException