Package com.amazonaws.kinesisvideo.encoding

Class ChunkDecoder

java.lang.Object

com.amazonaws.kinesisvideo.encoding.ChunkDecoder

public final class ChunkDecoder
extends Object

Method Summary

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

Methods inherited from class java.lang.Object

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

Method Detail

decodeHeaders

public static Map<String,String> decodeHeaders(InputStream inputStream)

readStatusLine

public static ResponseStatus readStatusLine(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(InputStream inputStream)

parseEntireTextResponse

public static Response parseEntireTextResponse(InputStream inputStream)

decodeAckInResponseBody

public static Integer decodeAckInResponseBody(InputStream inputStream,
                                              Consumer<String> ackTimestampConsumer)

parseResponseBodyAndDecodeAck

public static Integer parseResponseBodyAndDecodeAck(BufferedReader reader,
                                                    Consumer<String> ackTimestampConsumer)