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) - Method in interface xyz.cofe.trambda.tcp.TrEventPublisher

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

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

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

addListener(TrListener, boolean) - Method in interface xyz.cofe.trambda.tcp.TrEventPublisher

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

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

клиент TCP

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

Завершение работы клиента, вызывает TcpClient.shutdown()

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

Результат компиляции Compile

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

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

consumer - Variable 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

createThread(Runnable, Socket) - Method in class xyz.cofe.trambda.tcp.TcpClient

Создание потока для чтения входящих сообщений

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

errConsumer - Variable in class xyz.cofe.trambda.tcp.ResultConsumer

Подписчик на ошибочное выполнение

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

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

errorConsumers - Variable in class xyz.cofe.trambda.tcp.ResultConsumer

Карта подписчиков на ошибочное выполнение запроса

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

Выполнение ранее скомпилированной лямбды (TcpClient.compile(LambdaDump))

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

Выполнение ранее скомпилированной лямбды

Execute - Class in xyz.cofe.trambda.tcp

Запрос выполнения скомпилированной лямбды, Предварительно лямбда должны быть скомпилирована: Compile, CompileResult, TcpClient.compile(LambdaDump), см call(Fn1, SerializedLambda, LambdaDump) ()}

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

ExecuteResult - Class in xyz.cofe.trambda.tcp

Результат выполнения Execute

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

Возвращает ссылку на клиента TCP

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

Возвращает дамп лямбды

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

Возвращает обработчики ошибок на конкретные запросы TcpHeader.getSid()

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

Возвращает хеш лямбды, см Compile, CompileResult

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

Возвращает размер заголовка

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

Канал/поток входящих сообщений

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

Возвращает ключ-идентификатор лямбды, см Compile, CompileResult

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

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

getListeners() - Method in interface xyz.cofe.trambda.tcp.TrEventPublisher

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

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

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

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

Логирование

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.

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

Канал/поток исходящих сообщений

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

Возвращает имя издателя, см TcpServer.publisher(String), TcpServer.publishers(Class)

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

Возвращает имя издателя, см TcpServer.publisher(String), TcpServer.publishers(Class)

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

Возвращает обработчики на конкретные запросы TcpHeader.getSid()

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

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

hasListener(TrListener) - Method in interface xyz.cofe.trambda.tcp.TrEventPublisher

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

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

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

Заголовок пакета

header - Variable in class xyz.cofe.trambda.tcp.TcpProtocol.SentRawData

header - Variable in class xyz.cofe.trambda.tcp.TcpSession.IncomingMessageEvent

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

Значение заголовка TCP пакета, см TcpHeader

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

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

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

headerValues - Variable in class xyz.cofe.trambda.tcp.TcpProtocol.SentRawData

headerValues - Variable in class xyz.cofe.trambda.tcp.TcpSession.OutgoingMessageEvent

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

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

Возвращает адрес расположения сервера

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

Указывает адрес расположения сервера

I

IncomingMessageEvent(TcpSession<ENV>, T, TcpHeader) - Constructor for class xyz.cofe.trambda.tcp.TcpSession.IncomingMessageEvent

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

Подписка на серверные события, вызывается в клиентском коде

listen(TrEventPublisher, Consumer<Compile>) - Static method in class xyz.cofe.trambda.tcp.Compile

Подписка на события Compile

listen(TrEventPublisher, Consumer<CompileResult>) - Static method in class xyz.cofe.trambda.tcp.CompileResult

Подписка на события Compile

listen(TrEventPublisher, Consumer<ErrMessage>) - Static method in class xyz.cofe.trambda.tcp.ErrMessage

Подписка на события Compile

listen(TrEventPublisher, Consumer<Execute>) - Static method in class xyz.cofe.trambda.tcp.Execute

Подписка на события Compile

listen(TrEventPublisher, Consumer<ExecuteResult>) - Static method in class xyz.cofe.trambda.tcp.ExecuteResult

Подписка на события Compile

listen(TrEventPublisher, Consumer<Ping>) - Static method in class xyz.cofe.trambda.tcp.Ping

Подписка на события Compile

listen(TrEventPublisher, Consumer<Pong>) - Static method in class xyz.cofe.trambda.tcp.Pong

Подписка на события Compile

listen(TrEventPublisher, Consumer<ServerEvent>) - Static method in class xyz.cofe.trambda.tcp.ServerEvent

Подписка на события Compile

listen(TrEventPublisher, Consumer<Subscribe>) - Static method in class xyz.cofe.trambda.tcp.Subscribe

Подписка на события Compile

listen(TrEventPublisher, Consumer<SubscribeResult>) - Static method in class xyz.cofe.trambda.tcp.SubscribeResult

Подписка на события Compile

listen(TrEventPublisher, Consumer<UnSubscribe>) - Static method in class xyz.cofe.trambda.tcp.UnSubscribe

Подписка на события Compile

listen(TrEventPublisher, Consumer<UnSubscribeResult>) - Static method in class xyz.cofe.trambda.tcp.UnSubscribeResult

Подписка на события Compile

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

Вычисление MD5

message - Variable in class xyz.cofe.trambda.tcp.TcpProtocol.SentRawData

message - Variable in class xyz.cofe.trambda.tcp.TcpSession.MessageEvent

message - Variable in class xyz.cofe.trambda.tcp.TcpSession.OutgoingMessageEvent

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

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

Message - Interface in xyz.cofe.trambda.tcp

Сообщение которыми обмениваются клиент - сервер

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

Конструктор

messageId - Variable in class xyz.cofe.trambda.tcp.TcpProtocol.SentRawData

messageId - Variable in class xyz.cofe.trambda.tcp.TcpSession.OutgoingMessageEvent

method - Variable in class xyz.cofe.trambda.tcp.TcpProtocol.SentRawData

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

Добавляет еще одного подписчика на успешное выполнение.

OutgoingMessageEvent(TcpSession<ENV>, T, int, HeaderValue<?>...) - Constructor for class xyz.cofe.trambda.tcp.TcpSession.OutgoingMessageEvent

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

payload - Variable in class xyz.cofe.trambda.tcp.TcpProtocol.SentRawData

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 запрос

Ping - Class in xyz.cofe.trambda.tcp

Пинг запрос, ожидается ответ на него Pong

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

Pong - Class in xyz.cofe.trambda.tcp

Ответ на Ping запрос

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

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

Передача событий от сессии к подписчикам сервера

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

port() - Method 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

The value of the pos field at the time the last mark method was called.

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

При получении Ping сообщения, отсылает ответ Pong

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

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

При получении ответа Pong уведомляет подписанотов TcpProtocol.ping(Consumer), тех кто отправил запрос Ping

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

Обработка входящего серверного события Уведомляет подписчиков TcpProtocol.listenServerEvent(String, Consumer) о серверном событии

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

Обработка запроса подписки на события сервера, см Subscribe

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

Отписка от событий сервера

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

управление TCP потоком

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

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

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

Читает сообщение Message из входного потока (TcpProtocol.getInput).

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

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

removeAllListeners() - Method in interface xyz.cofe.trambda.tcp.TrEventPublisher

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

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

Отписка от событий сервера

req - Variable in class xyz.cofe.trambda.tcp.ResultConsumer

запрос

responseConsumers - Variable in class xyz.cofe.trambda.tcp.ResultConsumer

Карта подписчиков на успешное выполнение запроса

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

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

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

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

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

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

sentRawDataConsumer - Variable 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

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

session - Variable in class xyz.cofe.trambda.tcp.TcpSession.MessageEvent

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

Указывает хеш лямбды, см Compile, CompileResult

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

Указывает ключ-идентификатор лямбды, см Compile, CompileResult

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

Указывает имя издателя, см TcpServer.publisher(String), TcpServer.publishers(Class)

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

Указывает имя издателя, см TcpServer.publisher(String), TcpServer.publishers(Class)

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

Завершение работы клиента
Нельзя вызывать из того же потока, который осуществляет чтение входящих сообщений - TcpClient.socketReaderThread

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.TcpProtocol

Счетчик/генератор идентификаторов сообщений

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.TcpProtocol

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

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

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

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

Сокет сессии

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

Поток читающих входящие сообщения

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

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

Подписка на события сервера, см Subscribe

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

Подписка на события сервера, см Subscribe

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

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

Подписка на события сервера
Используйте возможности клиента TcpClient.subscribe(String, Consumer)

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

Создание proxy подписчика

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

Клиент для TcpSession/TcpServer.

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

Конструктор
создает (TcpClient.createThread(Runnable, Socket)) и запускает поток для чтения входящих сообщений Message.

TcpHeader - Class in xyz.cofe.trambda.tcp

Заголовок 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(OutputStream, InputStream, Logger, Consumer<TcpProtocol.SentRawData>) - Constructor for class xyz.cofe.trambda.tcp.TcpProtocol

Конструктор

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

Конструктор

TcpProtocol(Socket, Consumer<TcpProtocol.SentRawData>) - Constructor for class xyz.cofe.trambda.tcp.TcpProtocol

Конструктор

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

Конструктор

TcpProtocol.SentRawData - Class in xyz.cofe.trambda.tcp

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>, Consumer<TrEvent>) - Constructor for class xyz.cofe.trambda.tcp.TcpSession

Конструктор

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

Конструктор

TcpSession.IncomingMessageEvent<T extends Message,ENV> - Class in xyz.cofe.trambda.tcp

Входящие сообщение

TcpSession.MessageEvent<T extends Message,ENV> - Class in xyz.cofe.trambda.tcp

Сообщение

TcpSession.OutgoingMessageEvent<T extends Message,ENV> - Class in xyz.cofe.trambda.tcp

Исходящие сообщение

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

События сервера/сессии TcpServer

TrEventPublisher - Interface in xyz.cofe.trambda.tcp

Издатель событий TrEvent

TrListener - Interface in xyz.cofe.trambda.tcp

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

U

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

Возвращает обработчик общих ошибок, см TcpProtocol.getErrorConsumers()

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

Указывает обработчик общих ошибок, см TcpProtocol.getErrorConsumers()

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

Возвращает обработчик сообщений, см TcpProtocol.getResponseConsumers()

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

Указывает обработчик сообщений, см TcpProtocol.getResponseConsumers()

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

Отписка от событий сервера
Используйте возможности клиента TcpClient.unsubscribe(String), TcpClient.unsubscribe(Consumer)

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

Пакет для передачи и вызова лямбд на сервер, поверх TCP протокола.

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