Package xyz.cofe.trambda.tcp

Class TcpQuery<ENV>

java.lang.Object

xyz.cofe.trambda.AsmQuery<ENV>

xyz.cofe.trambda.tcp.TcpQuery<ENV>

Type Parameters:

ENV - Сервис который предоставляется сервером

All Implemented Interfaces:

AutoCloseable, xyz.cofe.trambda.Query<ENV>

public class TcpQuery<ENV>
extends xyz.cofe.trambda.AsmQuery<ENV>
implements AutoCloseable

Клиент для выполнения лямбд на сервере

Для создания простого клиента посмотрите описание сервера TcpServer.

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TcpQuery.Builder<ENV>	Создатель клиента

Field Summary

Fields

Modifier and Type	Field	Description
protected TcpClient	client	клиент TCP
protected Map<xyz.cofe.fn.Fn1<?,?>,CompileResult>	fnKeys

Fields inherited from class xyz.cofe.trambda.AsmQuery

lambdaDumpInst, serLambda

Constructor Summary

Constructors

Constructor	Description
TcpQuery(TcpClient client)	Конструктор

Method Summary

Modifier and Type	Method	Description
protected <RES> RES	call(xyz.cofe.fn.Fn1<ENV,RES> fn, SerializedLambda sl, xyz.cofe.trambda.LambdaDump dump)	Реализация вызова лямбды
protected <RES> RES	call(CompileResult key, SerializedLambda sl)	Реализация вызова лямбды
void	close()	Завершение работы
static <ENV> TcpQuery.Builder<ENV>	create(Class<ENV> c)	Создание клиента
TcpClient	getClient()	Возвращает ссылку на клиента TCP
<T> T	subscribe(Class<T> cls)	Подписка на события сервера, см Subscribe
<T> TcpQuery<ENV>	subscribe(Class<T> cls, Consumer<T> publishers)	Подписка на события сервера, см Subscribe

Methods inherited from class xyz.cofe.trambda.AsmQuery

apply, lambdaDump

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

client

protected final TcpClient client

клиент TCP

fnKeys

protected final Map<xyz.cofe.fn.Fn1<?,?>,CompileResult> fnKeys

Constructor Detail

TcpQuery

public TcpQuery(TcpClient client)

Конструктор

Parameters:

client - клиент TCP

Method Detail

getClient

public TcpClient getClient()

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

Returns:

клиент TCP

close

public void close()
           throws Exception

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

Specified by:

close in interface AutoCloseable

Throws:

Exception - какие-то ошибки

create

public static <ENV> TcpQuery.Builder<ENV> create(Class<ENV> c)

Создание клиента

Type Parameters:

ENV - Класс сервиса

Parameters:

c - Сервис предоставляемый сервером

Returns:

Создатель клиента

call

protected <RES> RES call(xyz.cofe.fn.Fn1<ENV,RES> fn,
                         SerializedLambda sl,
                         xyz.cofe.trambda.LambdaDump dump)

Реализация вызова лямбды

Overrides:

call in class xyz.cofe.trambda.AsmQuery<ENV>

Type Parameters:

RES - результат вызова

Parameters:

fn - лямбда

sl - лямбда-сериализация

dump - дамп лямбды

Returns:

результат вызова

call

protected <RES> RES call(CompileResult key,
                         SerializedLambda sl)

Реализация вызова лямбды

Type Parameters:

RES - результат вызова

Parameters:

key - результат компиляции

sl - лямбда-сериализация

Returns:

результат вызова

subscribe

public <T> T subscribe(Class<T> cls)

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

Type Parameters:

T - Класс событий

Parameters:

cls - Класс событий

Returns:

Интерфейс подписки

subscribe

public <T> TcpQuery<ENV> subscribe(Class<T> cls,
                                   Consumer<T> publishers)

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

Type Parameters:

T - Класс событий

Parameters:

cls - Класс событий

publishers - подписчик

Returns:

SELF ссылка