ddmlib_proto.java

private ByteArrayOutputStream mPendingData = new ByteArrayOutputStream();
public void addOutput(byte[] data, int offset, int length) {
    mPendingData.write(data, offset, length);
    try {
        InstrumentationData.Session session =
                InstrumentationData.Session.parseFrom(mPendingData.toByteArray());
        mPendingData.reset();
        updateState(session);
    }
    catch (InvalidProtocolBufferException e) {
        // InvalidProtocolBufferException may happen if a given new output data is incomplete.
        // Let's just skip updating mSession and wait for incoming data.
    }