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, xyz.cofe.trambda.Query<ENV>

public class TcpQuery<ENV>
extends xyz.cofe.trambda.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<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 mdef)
protected <RES> RES	call(CompileResult key, SerializedLambda sl)
void	close()
static <ENV> TcpQuery.Builder<ENV>	create(Class<ENV> c)
TcpClient	getClient()
<T> T	subscribe(Class<T> cls)
<T> TcpQuery<ENV>	subscribe(Class<T> cls, Consumer<T> publishers)

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

fnKeys

protected final Map<xyz.cofe.fn.Fn1<?,?>,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(xyz.cofe.fn.Fn1<ENV,RES> fn,
                         SerializedLambda sl,
                         xyz.cofe.trambda.LambdaDump mdef)

Overrides:

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

call

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

subscribe

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

subscribe

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