com.amazonaws.kinesisvideo.encoding

Class ChunkDecoder

java.lang.Object

com.amazonaws.kinesisvideo.encoding.ChunkDecoder

public final class ChunkDecoder
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static int	arrayIndexOf(byte[] haystack, int tail, int head, byte[] needle)
static java.lang.Integer	decodeAckInResponseBody(java.io.InputStream inputStream, Consumer<java.lang.String> ackTimestampConsumer)
static java.util.Map<java.lang.String,java.lang.String>	decodeHeaders(java.io.InputStream inputStream)
static int	parseChunkSize(byte[] buffer, int tail, int head)
static Response	parseEntireTextResponse(java.io.InputStream inputStream)
static Response	parseStatusLineAndHeaders(java.io.InputStream inputStream)
static ResponseStatus	readStatusLine(java.io.InputStream inputStream)

Methods inherited from class java.lang.Object

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

Method Detail

decodeHeaders

public static java.util.Map<java.lang.String,java.lang.String> decodeHeaders(java.io.InputStream inputStream)

readStatusLine

public static ResponseStatus readStatusLine(java.io.InputStream inputStream)

arrayIndexOf

public static int arrayIndexOf(byte[] haystack,
                               int tail,
                               int head,
                               byte[] needle)

parseChunkSize

public static int parseChunkSize(byte[] buffer,
                                 int tail,
                                 int head)

parseStatusLineAndHeaders

public static Response parseStatusLineAndHeaders(java.io.InputStream inputStream)

parseEntireTextResponse

public static Response parseEntireTextResponse(java.io.InputStream inputStream)

decodeAckInResponseBody

public static java.lang.Integer decodeAckInResponseBody(java.io.InputStream inputStream,
                                                        Consumer<java.lang.String> ackTimestampConsumer)