Package xyz.cofe.trambda.tcp

Class TcpQuery<ENV>

java.lang.Object

xyz.cofe.trambda.AsmQuery<ENV>

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

All Implemented Interfaces:

AutoCloseable, Query<ENV>

public class TcpQuery<ENV>
extends AsmQuery<ENV>
implements AutoCloseable

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
protected Map<Fn<?,?>,CompileResult>	fnKeys

Fields inherited from class xyz.cofe.trambda.AsmQuery

fn2mdef, methods, serializedLambdas

Constructor Summary

Constructors

Constructor	Description
TcpQuery(TcpClient client)

Method Summary

Modifier and Type	Method	Description
protected <RES> RES	call(Fn<ENV,RES> fn, SerializedLambda sl, MethodDef mdef)
protected <RES> RES	call(CompileResult key, SerializedLambda sl)
void	close()
static <ENV> TcpQuery.Builder<ENV>	create(Class<ENV> c)
TcpClient	getClient()

Methods inherited from class xyz.cofe.trambda.AsmQuery

apply, idOf

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

fnKeys

protected final Map<Fn<?,?>,CompileResult> fnKeys

Constructor Detail

TcpQuery

public TcpQuery(TcpClient client)

Method Detail

getClient

public TcpClient getClient()

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)

call

protected <RES> RES call(Fn<ENV,RES> fn,
                         SerializedLambda sl,
                         MethodDef mdef)

Overrides:

call in class AsmQuery<ENV>

call

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