final class HttpNetwork.NetworkInputStream extends BufferedMessageInputStream
Modifier and Type | Field and Description |
---|---|
(package private) int |
ack |
(package private) int |
boot |
(package private) Message |
msg |
in
buf, compressedFlows, count, logmon, pos
Constructor and Description |
---|
NetworkInputStream() |
Modifier and Type | Method and Description |
---|---|
(package private) int |
getAckStamp() |
(package private) int |
getBootTS() |
(package private) Message |
getMessage() |
(package private) int |
readFrom(InputStream is,
int length)
Reads next header or message from inputstream
|
protected void |
readHeader()
Reads the protocol header from this output stream.
|
clean, read, read, readFully
getLogger, read, readInt, readMessage, readMessageHeader, readShort
available, close, mark, markSupported, reset, skip
int boot
int ack
Message msg
protected void readHeader() throws IOException
readHeader
in class MessageInputStream
IOException
- an error occurs.int readFrom(InputStream is, int length) throws Exception
is
- length
- Exception
Message getMessage()
int getBootTS()
int getAckStamp()
Copyright © 2023 ScalAgent D.T.. All rights reserved.