public abstract class DefaultExchange<T> extends Object implements ProtocolContext<T>, 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() |
T |
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) |
T |
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 |
me() |
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() |
T |
send() |
void |
setConnection(Channel conn) |
ConnState |
state() |
void |
waitUntilClosing() |
T |
write(byte[] bytes) |
T |
write(byte[] bytes,
int offset,
int length) |
T |
write(ByteBuffer buf) |
T |
write(File file) |
T |
write(String s) |
T |
writeln(String s) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
mode, nextOp, nextWrite
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 ProtocolContext<T>
public T write(String s)
write
in interface ProtocolContext<T>
public T writeln(String s)
writeln
in interface ProtocolContext<T>
public T write(byte[] bytes)
write
in interface ProtocolContext<T>
public T write(byte[] bytes, int offset, int length)
write
in interface ProtocolContext<T>
public T write(ByteBuffer buf)
write
in interface ProtocolContext<T>
public T write(File file)
write
in interface ProtocolContext<T>
public T close()
close
in interface ProtocolContext<T>
public T closeIf(boolean condition)
closeIf
in interface ProtocolContext<T>
public org.rapidoidx.buffer.Buf input()
input
in interface ProtocolContext<T>
public org.rapidoidx.buffer.Buf output()
output
in interface ProtocolContext<T>
public String readln()
readln
in interface ProtocolContext<T>
public String readN(int count)
readN
in interface ProtocolContext<T>
public InetSocketAddress getAddress()
getAddress
in interface ProtocolContext<T>
public RapidoidHelper helper()
helper
in interface ProtocolContext<T>
public long connId()
connId
in interface ProtocolContext<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 ProtocolContext<T>
public T async()
async
in interface ProtocolContext<T>
public boolean isAsync()
isAsync
in interface ProtocolContext<T>
public T done()
done
in interface ProtocolContext<T>
public T send()
send
in interface ProtocolContext<T>
public boolean isClosing()
isClosing
in interface ProtocolContext<T>
public boolean isClosed()
isClosed
in interface ProtocolContext<T>
public void waitUntilClosing()
waitUntilClosing
in interface ProtocolContext<T>
public void log(String msg)
log
in interface ProtocolContext<T>
public boolean isInitial()
isInitial
in interface ProtocolContext<T>
public ConnState state()
state
in interface ProtocolContext<T>
public ChannelHolder createHolder()
createHolder
in interface ProtocolContext<T>
protected T me()
Copyright © 2014–2015 Nikolche Mihajlovski and contributors. All rights reserved.