public class SocketRuntime extends Object
Modifier and Type | Field and Description |
---|---|
protected List<FunctionWrapper> |
functions |
protected Options |
options |
protected DefaultFuture |
rootFuture |
protected Transport |
transport |
Constructor and Description |
---|
SocketRuntime(Transport transport,
Options options,
DefaultFuture rootFuture,
List<FunctionWrapper> functions) |
Modifier and Type | Method and Description |
---|---|
protected com.ning.http.client.AsyncHttpClient.BoundRequestBuilder |
configureAHC(Request request) |
DefaultFuture |
future() |
com.ning.http.client.ListenableFuture<com.ning.http.client.Response> |
httpWrite(Request request,
Object object,
Object data) |
protected Object |
invokeEncoder(List<Encoder<? extends Object,?>> encoders,
Object instanceType) |
void |
webSocketWrite(Request request,
Object object,
Object data) |
Future |
write(Request request,
Object data) |
protected Transport transport
protected final Options options
protected final DefaultFuture rootFuture
protected final List<FunctionWrapper> functions
public SocketRuntime(Transport transport, Options options, DefaultFuture rootFuture, List<FunctionWrapper> functions)
public DefaultFuture future()
protected Object invokeEncoder(List<Encoder<? extends Object,?>> encoders, Object instanceType)
public Future write(Request request, Object data) throws IOException
IOException
public void webSocketWrite(Request request, Object object, Object data) throws IOException
IOException
public com.ning.http.client.ListenableFuture<com.ning.http.client.Response> httpWrite(Request request, Object object, Object data) throws IOException
IOException
protected com.ning.http.client.AsyncHttpClient.BoundRequestBuilder configureAHC(Request request)
Copyright © 2015. All Rights Reserved.