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

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`protected <RES> RES`	`call(xyz.cofe.fn.Fn1<ENV,RES> fn, SerializedLambda sl, 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)`

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

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

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

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

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

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

Modifier and Type	Field	Description
`protected TcpClient`	`client`
`protected Map<xyz.cofe.fn.Fn1<?,?>,CompileResult>`	`fnKeys`

Class TcpQuery<ENV>