public abstract class DefaultExchange<T,W> extends Object implements CtxFull<T,W>, org.rapidoidx.buffer.BufProvider, org.rapidoid.util.Resetable, org.rapidoid.util.Constants
Modifier and Type | Field and Description |
---|---|
protected Channel |
conn |
protected AtomicLong |
totalWritten |
Constructor and Description |
---|
DefaultExchange() |
Modifier and Type | Method and Description |
---|---|
String |
address() |
W |
async() |
protected org.rapidoidx.data.BinaryMultiData |
binaryMultiData(org.rapidoidx.data.KeyValueRanges ranges) |
org.rapidoidx.buffer.Buf |
buffer() |
T |
close() |
T |
closeIf(boolean condition) |
long |
connId() |
ChannelHolder |
createHolder() |
protected org.rapidoidx.data.Data |
data(org.rapidoidx.data.Range range) |
protected org.rapidoidx.data.Data |
decodedData(org.rapidoidx.data.Range range) |
W |
done() |
InetSocketAddress |
getAddress() |
long |
getTotalWritten() |
RapidoidHelper |
helper() |
org.rapidoidx.buffer.Buf |
input() |
boolean |
isAsync() |
boolean |
isClosed() |
boolean |
isClosing() |
boolean |
isInitial() |
void |
log(String msg) |
protected T |
meT() |
protected W |
meW() |
protected org.rapidoidx.data.MultiData |
multiData(org.rapidoidx.data.KeyValueRanges ranges) |
org.rapidoidx.buffer.Buf |
output() |
String |
readln() |
String |
readN(int count) |
void |
reset() |
T |
restart() |
W |
send() |
void |
setConnection(Channel conn) |
ConnState |
state() |
void |
waitUntilClosing() |
W |
write(byte[] bytes) |
W |
write(byte[] bytes,
int offset,
int length) |
W |
write(ByteBuffer buf) |
W |
write(File file) |
W |
write(String s) |
W |
writeJSON(Object value) |
W |
writeln(String s) |
protected Channel conn
protected AtomicLong totalWritten
public void reset()
reset
in interface org.rapidoid.util.Resetable
public void setConnection(Channel conn)
public String address()
address
in interface CtxConnection<T>
public W write(byte[] bytes, int offset, int length)
public W write(ByteBuffer buf)
public T close()
close
in interface CtxConnection<T>
public T closeIf(boolean condition)
closeIf
in interface CtxConnection<T>
public InetSocketAddress getAddress()
getAddress
in interface CtxConnection<T>
public RapidoidHelper helper()
public long connId()
connId
in interface CtxConnection<T>
protected org.rapidoidx.data.Data data(org.rapidoidx.data.Range range)
protected org.rapidoidx.data.Data decodedData(org.rapidoidx.data.Range range)
protected org.rapidoidx.data.MultiData multiData(org.rapidoidx.data.KeyValueRanges ranges)
protected org.rapidoidx.data.BinaryMultiData binaryMultiData(org.rapidoidx.data.KeyValueRanges ranges)
public org.rapidoidx.buffer.Buf buffer()
buffer
in interface org.rapidoidx.buffer.BufProvider
public long getTotalWritten()
public T restart()
restart
in interface CtxProtocol<T>
public boolean isAsync()
isAsync
in interface CtxConnection<T>
public boolean isClosing()
isClosing
in interface CtxConnection<T>
public boolean isClosed()
isClosed
in interface CtxConnection<T>
public void waitUntilClosing()
waitUntilClosing
in interface CtxConnection<T>
public void log(String msg)
log
in interface CtxConnection<T>
public boolean isInitial()
isInitial
in interface CtxProtocol<T>
public ChannelHolder createHolder()
createHolder
in interface CtxState<T>
protected T meT()
protected W meW()
Copyright © 2014–2015 Nikolche Mihajlovski. All rights reserved.