org.jredis.ri.alphazero.protocol

Class SyncProtocol.SyncMultiLineResponseBase

java.lang.Object

org.jredis.ri.alphazero.protocol.ResponseSupport

org.jredis.ri.alphazero.protocol.SyncProtocol.SyncResponseBase

org.jredis.ri.alphazero.protocol.SyncProtocol.SyncMultiLineResponseBase

All Implemented Interfaces:

Message, Response

Direct Known Subclasses:

SyncProtocol.SyncBulkResponse, SyncProtocol.SyncMultiBulkResponse

Enclosing class:

SyncProtocol

public abstract class SyncProtocol.SyncMultiLineResponseBase
extends SyncProtocol.SyncResponseBase

Abstract base for all multiline responses (as of now, Bulk and MultBulk).

Since:

alpha.0 TODO: Use overflow buffers to increase read efficiency.

Version:

alpha.0, Sep 2, 2009

Author:

Joubin (alphazero@sensesay.net)

Nested Class Summary

Nested classes/interfaces inherited from interface org.jredis.protocol.Response

Response.Type

Field Summary

Fields inherited from class org.jredis.ri.alphazero.protocol.ResponseSupport

cmd, didRead, isError, status, type

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SyncMultiLineResponseBase(byte[] buffer, Command cmd, Response.Type type)

Method Summary

Modifier and Type	Method and Description
byte[]	readBulkData(InputStream in, int length) Will read up expected bulkdata bytes from the input stream.

Methods inherited from class org.jredis.ri.alphazero.protocol.SyncProtocol.SyncResponseBase

reset

Methods inherited from class org.jredis.ri.alphazero.protocol.ResponseSupport

assertResponseRead, didRead, didRead, getStatus, getType, isError, write

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jredis.connector.Message

read

Constructor Detail

SyncMultiLineResponseBase

protected SyncMultiLineResponseBase(byte[] buffer,
                                    Command cmd,
                                    Response.Type type)

Method Detail

readBulkData

public final byte[] readBulkData(InputStream in,
                                 int length)
                          throws IOException,
                                 RuntimeException

Will read up expected bulkdata bytes from the input stream. Routine will also read in the last two bytes and will check that they are indeed CRLF.

Parameters:

in - the stream to read from.

length - expected bulk data length (NOT including the trailing CRLF).

Returns:

a byte[] of length.

Throws:

IOException

IllegalArgumentException - if could not read the bulk data

RuntimeException