A B C E F G H I L M N O P R S T U W X
All Classes All Packages

A

addEvent(TrEvent) - Method in class xyz.cofe.trambda.tcp.TcpClient

Добавляет событие в очередь

addEvent(TrEvent) - Method in class xyz.cofe.trambda.tcp.TcpServer

Добавляет событие в очередь

addEvent(TrEvent) - Method in class xyz.cofe.trambda.tcp.TcpSession

Добавляет событие в очередь

addListener(TrListener) - Method in class xyz.cofe.trambda.tcp.TcpClient

Добавление подписчика.

addListener(TrListener) - Method in class xyz.cofe.trambda.tcp.TcpServer

Добавление подписчика.

addListener(TrListener) - Method in class xyz.cofe.trambda.tcp.TcpSession

Добавление подписчика.

addListener(TrListener, boolean) - Method in class xyz.cofe.trambda.tcp.TcpClient

Добавление подписчика.

addListener(TrListener, boolean) - Method in class xyz.cofe.trambda.tcp.TcpServer

Добавление подписчика.

addListener(TrListener, boolean) - Method in class xyz.cofe.trambda.tcp.TcpSession

Добавление подписчика.

addSesListener(TcpSession<ENV>) - Method in class xyz.cofe.trambda.tcp.TcpServer

Добавление подписчика sesListener на события сессии

asString() - Method in interface xyz.cofe.trambda.tcp.HeaderValue

asString() - Method in class xyz.cofe.trambda.tcp.HeaderValue.BoolValue

asString() - Method in class xyz.cofe.trambda.tcp.HeaderValue.IntValue

asString() - Method in class xyz.cofe.trambda.tcp.HeaderValue.StringValue

B

BoolValue(String, boolean) - Constructor for class xyz.cofe.trambda.tcp.HeaderValue.BoolValue

BuffInputStream - Class in xyz.cofe.trambda.tcp

BuffInputStream(InputStream) - Constructor for class xyz.cofe.trambda.tcp.BuffInputStream

BuffInputStream(InputStream, int) - Constructor for class xyz.cofe.trambda.tcp.BuffInputStream

build() - Method in class xyz.cofe.trambda.tcp.TcpQuery.Builder

Builder() - Constructor for class xyz.cofe.trambda.tcp.TcpQuery.Builder

C

call(Fn1<ENV, RES>, SerializedLambda, LambdaDump) - Method in class xyz.cofe.trambda.tcp.TcpQuery

call(CompileResult, SerializedLambda) - Method in class xyz.cofe.trambda.tcp.TcpQuery

client - Variable in class xyz.cofe.trambda.tcp.TcpQuery

close() - Method in class xyz.cofe.trambda.tcp.TcpClient

close() - Method in class xyz.cofe.trambda.tcp.TcpQuery

close() - Method in class xyz.cofe.trambda.tcp.TcpServer

Завершение работы сервера

close() - Method in class xyz.cofe.trambda.tcp.TcpSession

closeSessions() - Method in class xyz.cofe.trambda.tcp.TcpServer

Завершение всех сессий

closeSocket() - Method in class xyz.cofe.trambda.tcp.TcpServer

Закрытие сокета

compareTo(TcpSession) - Method in class xyz.cofe.trambda.tcp.TcpSession

compile(LambdaDump) - Method in class xyz.cofe.trambda.tcp.TcpClient

compile(LambdaDump) - Method in class xyz.cofe.trambda.tcp.TcpProtocol

compile(LambdaDump, String) - Method in class xyz.cofe.trambda.tcp.TcpSession

Compile - Class in xyz.cofe.trambda.tcp

Compile() - Constructor for class xyz.cofe.trambda.tcp.Compile

compiled - Variable in class xyz.cofe.trambda.tcp.TcpSession

compileId - Variable in class xyz.cofe.trambda.tcp.TcpSession

CompileResult - Class in xyz.cofe.trambda.tcp

CompileResult() - Constructor for class xyz.cofe.trambda.tcp.CompileResult

configure(Consumer<Req>) - Method in class xyz.cofe.trambda.tcp.ResultConsumer

count() - Method in class xyz.cofe.trambda.tcp.BuffInputStream

create(Boolean) - Method in class xyz.cofe.trambda.tcp.HeaderValue.BoolValue

create(Class<ENV>) - Static method in class xyz.cofe.trambda.tcp.TcpQuery

create(Integer) - Method in class xyz.cofe.trambda.tcp.HeaderValue.IntValue

create(String) - Static method in class xyz.cofe.trambda.tcp.HeaderValue.IntValue

create(String) - Method in class xyz.cofe.trambda.tcp.HeaderValue.StringValue

create(String, boolean) - Static method in class xyz.cofe.trambda.tcp.HeaderValue.BoolValue

create(String, int) - Static method in class xyz.cofe.trambda.tcp.HeaderValue.IntValue

create(String, String) - Static method in class xyz.cofe.trambda.tcp.HeaderValue.StringValue

create(Socket) - Method in class xyz.cofe.trambda.tcp.TcpServer

Создание сессии

create(T) - Method in interface xyz.cofe.trambda.tcp.HeaderValue

createProxyPublisher(Class<T>) - Method in class xyz.cofe.trambda.tcp.TcpServer

createPublisher(String) - Method in class xyz.cofe.trambda.tcp.TcpServer

E

encode(String, byte[]) - Static method in class xyz.cofe.trambda.tcp.TcpHeader

encode(String, byte[], HeaderValue<? extends Object>...) - Static method in class xyz.cofe.trambda.tcp.TcpHeader

envBuilder - Variable in class xyz.cofe.trambda.tcp.TcpServer

Функция получения сервиса для новой сессии

equals(Object) - Method in class xyz.cofe.trambda.tcp.TcpSession

ErrMessage - Class in xyz.cofe.trambda.tcp

Сообщение о ошибке

ErrMessage() - Constructor for class xyz.cofe.trambda.tcp.ErrMessage

error(Throwable) - Method in class xyz.cofe.trambda.tcp.ErrMessage

Указывает текст ошибки

execute(CompileResult) - Method in class xyz.cofe.trambda.tcp.TcpClient

execute(CompileResult) - Method in class xyz.cofe.trambda.tcp.TcpProtocol

Execute - Class in xyz.cofe.trambda.tcp

Execute() - Constructor for class xyz.cofe.trambda.tcp.Execute

ExecuteResult - Class in xyz.cofe.trambda.tcp

ExecuteResult() - Constructor for class xyz.cofe.trambda.tcp.ExecuteResult

F

fetch() - Method in class xyz.cofe.trambda.tcp.ResultConsumer

fireClosed - Variable in class xyz.cofe.trambda.tcp.TcpServer

Информация когда было уведомление о закрытии сессии: ses.id / System.currentTimeMillis()

fireEvent(TrEvent) - Method in class xyz.cofe.trambda.tcp.TcpClient

Рассылка уведомления подписчикам

fireEvent(TrEvent) - Method in class xyz.cofe.trambda.tcp.TcpServer

Рассылка уведомления подписчикам

fireEvent(TrEvent) - Method in class xyz.cofe.trambda.tcp.TcpSession

Рассылка уведомления подписчикам

fnKeys - Variable in class xyz.cofe.trambda.tcp.TcpQuery

fromBytes(byte[]) - Static method in class xyz.cofe.trambda.tcp.Serializer

G

getCapturedArgs() - Method in class xyz.cofe.trambda.tcp.Execute

getClient() - Method in class xyz.cofe.trambda.tcp.TcpQuery

getDump() - Method in class xyz.cofe.trambda.tcp.Compile

getErrorConsumers() - Method in class xyz.cofe.trambda.tcp.TcpProtocol

getEvent() - Method in class xyz.cofe.trambda.tcp.ServerEvent

getFinished() - Method in class xyz.cofe.trambda.tcp.ExecuteResult

getFinishedNano() - Method in class xyz.cofe.trambda.tcp.ExecuteResult

getHash() - Method in class xyz.cofe.trambda.tcp.CompileResult

getHash() - Method in class xyz.cofe.trambda.tcp.Execute

getHeader() - Method in class xyz.cofe.trambda.tcp.RawPack

getHeader() - Method in class xyz.cofe.trambda.tcp.RawPackReadonly

getHeaderSize() - Method in class xyz.cofe.trambda.tcp.TcpHeader

getKeepAlive() - Method in class xyz.cofe.trambda.tcp.TcpSession

Проверяет, включен ли SO_KEEPALIVE.

getKey() - Method in class xyz.cofe.trambda.tcp.CompileResult

getKey() - Method in class xyz.cofe.trambda.tcp.Execute

getListeners() - Method in class xyz.cofe.trambda.tcp.TcpClient

Получение списка подписчиков

getListeners() - Method in class xyz.cofe.trambda.tcp.TcpServer

Получение списка подписчиков

getListeners() - Method in class xyz.cofe.trambda.tcp.TcpSession

Получение списка подписчиков

getLocalAddress() - Method in class xyz.cofe.trambda.tcp.TcpSession

Возвращает локальный адрес сессии

getMessage() - Method in class xyz.cofe.trambda.tcp.ErrMessage

Возвращает текст ошибки

getMethodName() - Method in class xyz.cofe.trambda.tcp.TcpHeader

getName() - Method in class xyz.cofe.trambda.tcp.HeaderValue.BoolValue

getName() - Method in interface xyz.cofe.trambda.tcp.HeaderValue

getName() - Method in class xyz.cofe.trambda.tcp.HeaderValue.IntValue

getName() - Method in class xyz.cofe.trambda.tcp.HeaderValue.StringValue

getOOBInline() - Method in class xyz.cofe.trambda.tcp.TcpSession

Проверяет, включен ли SO_OOBINLINE.

getPayload() - Method in class xyz.cofe.trambda.tcp.RawPack

getPayload() - Method in class xyz.cofe.trambda.tcp.RawPackReadonly

getPayloadMd5() - Method in class xyz.cofe.trambda.tcp.TcpHeader

getPayloadSize() - Method in class xyz.cofe.trambda.tcp.TcpHeader

getPublisher() - Method in class xyz.cofe.trambda.tcp.ServerEvent

getPublisher() - Method in class xyz.cofe.trambda.tcp.Subscribe

getPublisher() - Method in class xyz.cofe.trambda.tcp.UnSubscribe

getReferrer() - Method in class xyz.cofe.trambda.tcp.TcpHeader

getRemoteAddress() - Method in class xyz.cofe.trambda.tcp.TcpSession

Возвращает адрес клиента

getResponseConsumers() - Method in class xyz.cofe.trambda.tcp.TcpProtocol

getReuseAddress() - Method in class xyz.cofe.trambda.tcp.TcpSession

Проверяет, включен ли SO_REUSEADDR.

getSecurMessages() - Method in error xyz.cofe.trambda.tcp.SecurError

getServer() - Method in class xyz.cofe.trambda.tcp.TcpServer.SessionClosed

Возвращает сервер

getServer() - Method in class xyz.cofe.trambda.tcp.TcpServer.SessionCreated

Возвращает сервер

getServer() - Method in class xyz.cofe.trambda.tcp.TcpSession

Возвращает сервер

getService() - Method in class xyz.cofe.trambda.tcp.TcpSession

Возвращает предоставляемый сервис клиенту

getSession() - Method in class xyz.cofe.trambda.tcp.TcpServer.SessionClosed

Возвращает сессию

getSession() - Method in class xyz.cofe.trambda.tcp.TcpServer.SessionCreated

Возвращает сессию

getSession() - Method in class xyz.cofe.trambda.tcp.TcpSession.SessionFinished

getSessions() - Method in class xyz.cofe.trambda.tcp.TcpServer

Возвращает сессии

getSid() - Method in class xyz.cofe.trambda.tcp.TcpHeader

getStarted() - Method in class xyz.cofe.trambda.tcp.ExecuteResult

getStartedNano() - Method in class xyz.cofe.trambda.tcp.ExecuteResult

getSubscribeTime() - Method in class xyz.cofe.trambda.tcp.SubscribeResult

getSubscribeTime() - Method in class xyz.cofe.trambda.tcp.UnSubscribeResult

getTcpNoDelay() - Method in class xyz.cofe.trambda.tcp.TcpSession

Проверяет, включен ли TCP_NODELAY.

getValue() - Method in class xyz.cofe.trambda.tcp.ExecuteResult

getValue() - Method in class xyz.cofe.trambda.tcp.HeaderValue.BoolValue

getValue() - Method in interface xyz.cofe.trambda.tcp.HeaderValue

getValue() - Method in class xyz.cofe.trambda.tcp.HeaderValue.IntValue

getValue() - Method in class xyz.cofe.trambda.tcp.HeaderValue.StringValue

getValues() - Method in class xyz.cofe.trambda.tcp.TcpHeader

H

Hash - Class in xyz.cofe.trambda.tcp

Hash() - Constructor for class xyz.cofe.trambda.tcp.Hash

hashCode() - Method in class xyz.cofe.trambda.tcp.TcpSession

hasListener(TrListener) - Method in class xyz.cofe.trambda.tcp.TcpClient

Проверка наличия подписчика в списке обработки

hasListener(TrListener) - Method in class xyz.cofe.trambda.tcp.TcpServer

Проверка наличия подписчика в списке обработки

hasListener(TrListener) - Method in class xyz.cofe.trambda.tcp.TcpSession

Проверка наличия подписчика в списке обработки

hasParamsError(Method) - Method in class xyz.cofe.trambda.tcp.PubProxy

header - Variable in class xyz.cofe.trambda.tcp.RawPack

HeaderValue<T> - Interface in xyz.cofe.trambda.tcp

HeaderValue.BoolValue - Class in xyz.cofe.trambda.tcp

HeaderValue.IntValue - Class in xyz.cofe.trambda.tcp

HeaderValue.StringValue - Class in xyz.cofe.trambda.tcp

host - Variable in class xyz.cofe.trambda.tcp.TcpQuery.Builder

host(String) - Method in class xyz.cofe.trambda.tcp.TcpQuery.Builder

I

IntValue(String, int) - Constructor for class xyz.cofe.trambda.tcp.HeaderValue.IntValue

isBound() - Method in class xyz.cofe.trambda.tcp.TcpSession

Возвращает состояние привязки сокета.

isClosed() - Method in class xyz.cofe.trambda.tcp.TcpSession

Возвращает закрытое состояние сокета.

isInputShutdown() - Method in class xyz.cofe.trambda.tcp.TcpSession

Возвращает, закрыта ли половина соединения сокета для чтения.

isOutputShutdown() - Method in class xyz.cofe.trambda.tcp.TcpSession

Возвращает, закрыта ли половина записи сокета соединения.

isPayloadChecksumMatched() - Method in class xyz.cofe.trambda.tcp.RawPackReadonly

L

listen(Publisher.Subscriber<T>) - Method in class xyz.cofe.trambda.tcp.Publisher

listeners - Variable in class xyz.cofe.trambda.tcp.TcpClient

listeners - Variable in class xyz.cofe.trambda.tcp.TcpServer

listeners - Variable in class xyz.cofe.trambda.tcp.TcpSession

listenServerEvent(String, Consumer<ServerEvent>) - Method in class xyz.cofe.trambda.tcp.TcpProtocol

M

markpos() - Method in class xyz.cofe.trambda.tcp.BuffInputStream

matched(byte[], int, int) - Method in class xyz.cofe.trambda.tcp.TcpHeader

md5(byte[], int, int) - Static method in class xyz.cofe.trambda.tcp.Hash

message(String) - Method in class xyz.cofe.trambda.tcp.ErrMessage

Указывает текст ошибки

Message - Interface in xyz.cofe.trambda.tcp

methodDefHash2compileKey - Variable in class xyz.cofe.trambda.tcp.TcpSession

N

notification(T) - Method in interface xyz.cofe.trambda.tcp.Publisher.Subscriber

notImpl(Method) - Method in class xyz.cofe.trambda.tcp.PubProxy

O

onFail(Consumer<ErrMessage>) - Method in class xyz.cofe.trambda.tcp.ResultConsumer

onFail(Consumer<ErrMessage>, Consumer<Tuple2<Consumer<ErrMessage>, Consumer<ErrMessage>>>) - Method in class xyz.cofe.trambda.tcp.ResultConsumer

onSuccess(Consumer<Res>) - Method in class xyz.cofe.trambda.tcp.ResultConsumer

onSuccess(Consumer<Res>, Consumer<Tuple2<Consumer<Res>, Consumer<Res>>>) - Method in class xyz.cofe.trambda.tcp.ResultConsumer

P

parse(byte[], int, int) - Static method in class xyz.cofe.trambda.tcp.TcpHeader

parse(String) - Method in class xyz.cofe.trambda.tcp.HeaderValue.BoolValue

parse(String) - Method in class xyz.cofe.trambda.tcp.HeaderValue.IntValue

parse(String) - Method in interface xyz.cofe.trambda.tcp.HeaderValue

parse(String) - Method in class xyz.cofe.trambda.tcp.HeaderValue.StringValue

parse(TcpHeader) - Method in interface xyz.cofe.trambda.tcp.HeaderValue

payload - Variable in class xyz.cofe.trambda.tcp.RawPack

payloadMessage() - Method in class xyz.cofe.trambda.tcp.RawPackReadonly

ping(Consumer<Pong>) - Method in class xyz.cofe.trambda.tcp.TcpClient

ping(Consumer<Pong>) - Method in class xyz.cofe.trambda.tcp.TcpProtocol

Ping - Class in xyz.cofe.trambda.tcp

Ping() - Constructor for class xyz.cofe.trambda.tcp.Ping

Pong - Class in xyz.cofe.trambda.tcp

Pong() - Constructor for class xyz.cofe.trambda.tcp.Pong

port - Variable in class xyz.cofe.trambda.tcp.TcpQuery.Builder

port(int) - Method in class xyz.cofe.trambda.tcp.TcpQuery.Builder

pos() - Method in class xyz.cofe.trambda.tcp.BuffInputStream

process(Compile, TcpHeader) - Method in class xyz.cofe.trambda.tcp.TcpSession

process(Execute, TcpHeader) - Method in class xyz.cofe.trambda.tcp.TcpSession

process(Message, TcpHeader) - Method in class xyz.cofe.trambda.tcp.TcpProtocol

process(Message, TcpHeader) - Method in class xyz.cofe.trambda.tcp.TcpSession

process(Ping, TcpHeader) - Method in class xyz.cofe.trambda.tcp.TcpProtocol

process(Ping, TcpHeader) - Method in class xyz.cofe.trambda.tcp.TcpSession

process(Pong, TcpHeader) - Method in class xyz.cofe.trambda.tcp.TcpProtocol

process(ServerEvent, TcpHeader) - Method in class xyz.cofe.trambda.tcp.TcpProtocol

process(Subscribe, TcpHeader) - Method in class xyz.cofe.trambda.tcp.TcpSession

process(UnSubscribe, TcpHeader) - Method in class xyz.cofe.trambda.tcp.TcpSession

proto - Variable in class xyz.cofe.trambda.tcp.TcpClient

proto - Variable in class xyz.cofe.trambda.tcp.TcpSession

Общие функции для протокола TCP как клиента, так и сервера

proxy(Class<T>) - Method in class xyz.cofe.trambda.tcp.PubProxy

publish(T) - Method in class xyz.cofe.trambda.tcp.Publisher

publisher(Method) - Method in class xyz.cofe.trambda.tcp.PubProxy

publisher(String) - Method in class xyz.cofe.trambda.tcp.TcpServer

Publisher<T extends Serializable> - Class in xyz.cofe.trambda.tcp

Publisher() - Constructor for class xyz.cofe.trambda.tcp.Publisher

Publisher.Subscriber<T> - Interface in xyz.cofe.trambda.tcp

publishers - Variable in class xyz.cofe.trambda.tcp.TcpServer

publishers(Class<T>) - Method in class xyz.cofe.trambda.tcp.TcpServer

PubProxy - Class in xyz.cofe.trambda.tcp

PubProxy() - Constructor for class xyz.cofe.trambda.tcp.PubProxy

R

RawPack - Class in xyz.cofe.trambda.tcp

RawPack(RawPack) - Constructor for class xyz.cofe.trambda.tcp.RawPack

RawPack(TcpHeader, byte[]) - Constructor for class xyz.cofe.trambda.tcp.RawPack

RawPack() - Method in class xyz.cofe.trambda.tcp.RawPack

RawPackReadonly - Class in xyz.cofe.trambda.tcp

RawPackReadonly(RawPack) - Constructor for class xyz.cofe.trambda.tcp.RawPackReadonly

RawPackReadonly(TcpHeader, byte[]) - Constructor for class xyz.cofe.trambda.tcp.RawPackReadonly

readNow() - Method in class xyz.cofe.trambda.tcp.TcpProtocol

received(RawPackReadonly) - Method in class xyz.cofe.trambda.tcp.TcpSession

receiveRaw(Optional<BuffInputStream>) - Method in class xyz.cofe.trambda.tcp.TcpProtocol

Получение сообщения из сети

referrer - Static variable in class xyz.cofe.trambda.tcp.TcpHeader

removeAllListeners() - Method in class xyz.cofe.trambda.tcp.TcpClient

Удаление всех подписчиков

removeAllListeners() - Method in class xyz.cofe.trambda.tcp.TcpServer

Удаление всех подписчиков

removeAllListeners() - Method in class xyz.cofe.trambda.tcp.TcpSession

Удаление всех подписчиков

removeListener(Publisher.Subscriber<T>) - Method in class xyz.cofe.trambda.tcp.Publisher

removeListener(TrListener) - Method in class xyz.cofe.trambda.tcp.TcpClient

Удаление подписчика из списка обработки

removeListener(TrListener) - Method in class xyz.cofe.trambda.tcp.TcpServer

Удаление подписчика из списка обработки

removeListener(TrListener) - Method in class xyz.cofe.trambda.tcp.TcpSession

Удаление подписчика из списка обработки

removeServerEventListener(Consumer<ServerEvent>) - Method in class xyz.cofe.trambda.tcp.TcpProtocol

ResultConsumer<Req extends Message,Res extends Message> - Class in xyz.cofe.trambda.tcp

ResultConsumer(TcpProtocol, Req, Map<Integer, Consumer<ErrMessage>>, Map<Integer, Consumer<Res>>) - Constructor for class xyz.cofe.trambda.tcp.ResultConsumer

retNotPublisher(Method) - Method in class xyz.cofe.trambda.tcp.PubProxy

run() - Method in class xyz.cofe.trambda.tcp.TcpServer

run() - Method in class xyz.cofe.trambda.tcp.TcpSession

runEventQueue() - Method in class xyz.cofe.trambda.tcp.TcpClient

Отправляет события из очереди подписчикам

runEventQueue() - Method in class xyz.cofe.trambda.tcp.TcpServer

Отправляет события из очереди подписчикам

runEventQueue() - Method in class xyz.cofe.trambda.tcp.TcpSession

Отправляет события из очереди подписчикам

S

SecurError - Error in xyz.cofe.trambda.tcp

SecurError(String) - Constructor for error xyz.cofe.trambda.tcp.SecurError

SecurError(String, Throwable) - Constructor for error xyz.cofe.trambda.tcp.SecurError

SecurError(String, Throwable, boolean, boolean) - Constructor for error xyz.cofe.trambda.tcp.SecurError

SecurError(Throwable) - Constructor for error xyz.cofe.trambda.tcp.SecurError

SecurError(List<SecurMessage<String, Tuple2<LambdaDump, LambdaNode>>>) - Constructor for error xyz.cofe.trambda.tcp.SecurError

securityFilter - Variable in class xyz.cofe.trambda.tcp.TcpServer

Функция фильтрации байт-кода

securityFilter - Variable in class xyz.cofe.trambda.tcp.TcpSession

Функция фильтра безопасности

send() - Method in class xyz.cofe.trambda.tcp.ResultConsumer

send(Message, Consumer<Integer>, HeaderValue<? extends Object>...) - Method in class xyz.cofe.trambda.tcp.TcpProtocol

Отправка сообщения

send(Message, HeaderValue<? extends Object>...) - Method in class xyz.cofe.trambda.tcp.TcpProtocol

Отправка сообщения

sendRaw(String, byte[], Consumer<Integer>, HeaderValue<? extends Object>...) - Method in class xyz.cofe.trambda.tcp.TcpProtocol

Отправка сообщения

Serializer - Class in xyz.cofe.trambda.tcp

Serializer() - Constructor for class xyz.cofe.trambda.tcp.Serializer

server - Variable in class xyz.cofe.trambda.tcp.TcpSession

Сервер

ServerEvent - Class in xyz.cofe.trambda.tcp

ServerEvent() - Constructor for class xyz.cofe.trambda.tcp.ServerEvent

serverEventListeners - Variable in class xyz.cofe.trambda.tcp.TcpProtocol

service - Variable in class xyz.cofe.trambda.tcp.TcpSession

Предоставляемый сервис клиенту

SessionClosed(TcpServer<ENV>, TcpSession<ENV>) - Constructor for class xyz.cofe.trambda.tcp.TcpServer.SessionClosed

sessionCloseTimeout() - Method in class xyz.cofe.trambda.tcp.TcpServer

Таймаут согласно которому сессия должна быть завершена

SessionCreated(TcpServer<ENV>, TcpSession<ENV>) - Constructor for class xyz.cofe.trambda.tcp.TcpServer.SessionCreated

SessionFinished(TcpSession<?>) - Constructor for class xyz.cofe.trambda.tcp.TcpSession.SessionFinished

sessions - Variable in class xyz.cofe.trambda.tcp.TcpServer

Сессии клиентов

sessionSoTimeout() - Method in class xyz.cofe.trambda.tcp.TcpServer

Возвращает значение SoTimeout Socket.setSoTimeout(int) для сессии

setCapturedArgs(List<Object>) - Method in class xyz.cofe.trambda.tcp.Execute

setDump(LambdaDump) - Method in class xyz.cofe.trambda.tcp.Compile

setEvent(Serializable) - Method in class xyz.cofe.trambda.tcp.ServerEvent

setFinished(long) - Method in class xyz.cofe.trambda.tcp.ExecuteResult

setFinishedNano(long) - Method in class xyz.cofe.trambda.tcp.ExecuteResult

setHash(String) - Method in class xyz.cofe.trambda.tcp.CompileResult

setHash(String) - Method in class xyz.cofe.trambda.tcp.Execute

setHeader(TcpHeader) - Method in class xyz.cofe.trambda.tcp.RawPack

setHeader(TcpHeader) - Method in class xyz.cofe.trambda.tcp.RawPackReadonly

setKey(Integer) - Method in class xyz.cofe.trambda.tcp.CompileResult

setKey(Integer) - Method in class xyz.cofe.trambda.tcp.Execute

setMessage(String) - Method in class xyz.cofe.trambda.tcp.ErrMessage

Указывает текст ошибки

setPayload(byte[]) - Method in class xyz.cofe.trambda.tcp.RawPack

setPayload(byte[]) - Method in class xyz.cofe.trambda.tcp.RawPackReadonly

setPublisher(String) - Method in class xyz.cofe.trambda.tcp.ServerEvent

setPublisher(String) - Method in class xyz.cofe.trambda.tcp.Subscribe

setPublisher(String) - Method in class xyz.cofe.trambda.tcp.UnSubscribe

setStarted(long) - Method in class xyz.cofe.trambda.tcp.ExecuteResult

setStartedNano(long) - Method in class xyz.cofe.trambda.tcp.ExecuteResult

setSubscribeTime(long) - Method in class xyz.cofe.trambda.tcp.SubscribeResult

setSubscribeTime(long) - Method in class xyz.cofe.trambda.tcp.UnSubscribeResult

setValue(Object) - Method in class xyz.cofe.trambda.tcp.ExecuteResult

shutdown() - Method in class xyz.cofe.trambda.tcp.TcpClient

shutdown() - Method in class xyz.cofe.trambda.tcp.TcpServer

Завершение всех сессий и остановка сервера

sid - Static variable in class xyz.cofe.trambda.tcp.TcpHeader

sid - Variable in class xyz.cofe.trambda.tcp.TcpSession

Идентификатор сессии

socket - Variable in class xyz.cofe.trambda.tcp.TcpClient

socket - Variable in class xyz.cofe.trambda.tcp.TcpServer

Сокет через который осуществляется общение

socket - Variable in class xyz.cofe.trambda.tcp.TcpSession

Сокет сессии

StringValue(String, String) - Constructor for class xyz.cofe.trambda.tcp.HeaderValue.StringValue

subscribe(Class<T>) - Method in class xyz.cofe.trambda.tcp.TcpQuery

subscribe(Class<T>, Consumer<T>) - Method in class xyz.cofe.trambda.tcp.TcpQuery

subscribe(String, Consumer<ServerEvent>) - Method in class xyz.cofe.trambda.tcp.TcpClient

subscribe(Subscribe) - Method in class xyz.cofe.trambda.tcp.TcpProtocol

subscribe(Subscribe, Consumer<ServerEvent>) - Method in class xyz.cofe.trambda.tcp.TcpClient

Subscribe - Class in xyz.cofe.trambda.tcp

Subscribe() - Constructor for class xyz.cofe.trambda.tcp.Subscribe

Subscribe(String) - Constructor for class xyz.cofe.trambda.tcp.Subscribe

subscriber(String) - Method in class xyz.cofe.trambda.tcp.TcpSession

SubscribeResult - Class in xyz.cofe.trambda.tcp

SubscribeResult() - Constructor for class xyz.cofe.trambda.tcp.SubscribeResult

subscribers - Variable in class xyz.cofe.trambda.tcp.TcpClient

subscribers - Variable in class xyz.cofe.trambda.tcp.TcpSession

subscribeTime - Variable in class xyz.cofe.trambda.tcp.SubscribeResult

subscribeTime - Variable in class xyz.cofe.trambda.tcp.UnSubscribeResult

T

TcpClient - Class in xyz.cofe.trambda.tcp

TcpClient(Socket) - Constructor for class xyz.cofe.trambda.tcp.TcpClient

TcpHeader - Class in xyz.cofe.trambda.tcp

TcpHeader(int, String, Map<String, String>) - Constructor for class xyz.cofe.trambda.tcp.TcpHeader

TcpProtocol - Class in xyz.cofe.trambda.tcp

Поддержка TCP протокола

TcpProtocol(OutputStream, InputStream, Logger) - Constructor for class xyz.cofe.trambda.tcp.TcpProtocol

Конструктор

TcpProtocol(Socket) - Constructor for class xyz.cofe.trambda.tcp.TcpProtocol

Конструктор

TcpProtocol(Socket, Logger) - Constructor for class xyz.cofe.trambda.tcp.TcpProtocol

Конструктор

TcpQuery<ENV> - Class in xyz.cofe.trambda.tcp

TcpQuery(TcpClient) - Constructor for class xyz.cofe.trambda.tcp.TcpQuery

TcpQuery.Builder<ENV> - Class in xyz.cofe.trambda.tcp

TcpServer<ENV> - Class in xyz.cofe.trambda.tcp

TCP Сервер для предоставления сервиса

TcpServer(ServerSocket, Function<TcpSession<ENV>, ENV>) - Constructor for class xyz.cofe.trambda.tcp.TcpServer

Создание сервера

TcpServer(ServerSocket, Function<TcpSession<ENV>, ENV>, SecurityFilter<String, Tuple2<LambdaDump, LambdaNode>>) - Constructor for class xyz.cofe.trambda.tcp.TcpServer

Создание сервера

TcpServer.SessionClosed<ENV> - Class in xyz.cofe.trambda.tcp

Событие о завершении сессии

TcpServer.SessionCreated<ENV> - Class in xyz.cofe.trambda.tcp

Событие о создании сессии

TcpSession<ENV> - Class in xyz.cofe.trambda.tcp

Сессия клиента

TcpSession(TcpServer<ENV>, Socket, Function<TcpSession<ENV>, ENV>) - Constructor for class xyz.cofe.trambda.tcp.TcpSession

Конструктор

TcpSession(TcpServer<ENV>, Socket, Function<TcpSession<ENV>, ENV>, SecurityFilter<String, Tuple2<LambdaDump, LambdaNode>>) - Constructor for class xyz.cofe.trambda.tcp.TcpSession

Конструктор

TcpSession.SessionFinished - Class in xyz.cofe.trambda.tcp

toBytes(Object) - Static method in class xyz.cofe.trambda.tcp.Serializer

toReadonly() - Method in class xyz.cofe.trambda.tcp.RawPack

toString() - Method in class xyz.cofe.trambda.tcp.Execute

toString() - Method in class xyz.cofe.trambda.tcp.ServerEvent

toString() - Method in class xyz.cofe.trambda.tcp.TcpServer.SessionClosed

toString() - Method in class xyz.cofe.trambda.tcp.TcpServer.SessionCreated

trEvent(TrEvent) - Method in interface xyz.cofe.trambda.tcp.TrListener

TrEvent - Interface in xyz.cofe.trambda.tcp

TrListener - Interface in xyz.cofe.trambda.tcp

U

unbindedError() - Method in class xyz.cofe.trambda.tcp.TcpProtocol

unbindedError(BiConsumer<ErrMessage, TcpHeader>) - Method in class xyz.cofe.trambda.tcp.TcpProtocol

unbindedMessage() - Method in class xyz.cofe.trambda.tcp.TcpProtocol

unbindedMessage(BiConsumer<Message, TcpHeader>) - Method in class xyz.cofe.trambda.tcp.TcpProtocol

unsubscribe(String) - Method in class xyz.cofe.trambda.tcp.TcpClient

unsubscribe(Consumer<? super ServerEvent>) - Method in class xyz.cofe.trambda.tcp.TcpClient

unsubscribe(UnSubscribe) - Method in class xyz.cofe.trambda.tcp.TcpClient

unsubscribe(UnSubscribe) - Method in class xyz.cofe.trambda.tcp.TcpProtocol

UnSubscribe - Class in xyz.cofe.trambda.tcp

UnSubscribe() - Constructor for class xyz.cofe.trambda.tcp.UnSubscribe

UnSubscribe(String) - Constructor for class xyz.cofe.trambda.tcp.UnSubscribe

unsubscribeAll() - Method in class xyz.cofe.trambda.tcp.TcpSession

UnSubscribeResult - Class in xyz.cofe.trambda.tcp

UnSubscribeResult() - Constructor for class xyz.cofe.trambda.tcp.UnSubscribeResult

W

withQueue(Runnable) - Method in class xyz.cofe.trambda.tcp.TcpClient

Запустить выполнение кода в блоке, и не рассылать уведомления до завершения блока кода

withQueue(Runnable) - Method in class xyz.cofe.trambda.tcp.TcpServer

Запустить выполнение кода в блоке, и не рассылать уведомления до завершения блока кода

withQueue(Runnable) - Method in class xyz.cofe.trambda.tcp.TcpSession

Запустить выполнение кода в блоке, и не рассылать уведомления до завершения блока кода

withQueue(Supplier<T>) - Method in class xyz.cofe.trambda.tcp.TcpClient

Запустить выполнение кода в блоке, и не рассылать уведомления до завершения блока кода

withQueue(Supplier<T>) - Method in class xyz.cofe.trambda.tcp.TcpServer

Запустить выполнение кода в блоке, и не рассылать уведомления до завершения блока кода

withQueue(Supplier<T>) - Method in class xyz.cofe.trambda.tcp.TcpSession

Запустить выполнение кода в блоке, и не рассылать уведомления до завершения блока кода

X

xyz.cofe.trambda.tcp - package xyz.cofe.trambda.tcp

A B C E F G H I L M N O P R S T U W X
All Classes All Packages