public class SSETransport extends StreamTransport
Transport
implementationcharSet, closed, connectOperationFuture, decoders, errorHandled, functions, isBinary, options, protocolEnabled, protocolReceived, request, requestBuilder, resolver, status, timer, underlyingFuture
Constructor and Description |
---|
SSETransport(com.ning.http.client.RequestBuilder requestBuilder,
Options options,
Request request,
List<FunctionWrapper> functions) |
Modifier and Type | Method and Description |
---|---|
Request.TRANSPORT |
name()
The transport name
|
com.ning.http.client.AsyncHandler.STATE |
onBodyPartReceived(com.ning.http.client.HttpResponseBodyPart bodyPart) |
com.ning.http.client.AsyncHandler.STATE |
onHeadersReceived(com.ning.http.client.HttpResponseHeaders headers) |
close, connectedFuture, error, errorHandled, future, onCompleted, onStatusReceived, onThrowable, registerF, status
public SSETransport(com.ning.http.client.RequestBuilder requestBuilder, Options options, Request request, List<FunctionWrapper> functions)
public Request.TRANSPORT name()
name
in interface Transport
name
in class StreamTransport
public com.ning.http.client.AsyncHandler.STATE onHeadersReceived(com.ning.http.client.HttpResponseHeaders headers) throws Exception
onHeadersReceived
in interface com.ning.http.client.AsyncHandler<String>
onHeadersReceived
in class StreamTransport
Exception
public com.ning.http.client.AsyncHandler.STATE onBodyPartReceived(com.ning.http.client.HttpResponseBodyPart bodyPart) throws Exception
onBodyPartReceived
in interface com.ning.http.client.AsyncHandler<String>
onBodyPartReceived
in class StreamTransport
Exception
Copyright © 2015. All Rights Reserved.