Package com.luna.common.net.async

Class CustomSseAsyncConsumer

java.lang.Object

org.apache.hc.core5.http.nio.entity.AbstractCharDataConsumer

org.apache.hc.client5.http.async.methods.AbstractCharResponseConsumer<SseResponse>

com.luna.common.net.async.CustomSseAsyncConsumer

All Implemented Interfaces:

org.apache.hc.core5.http.nio.AsyncDataConsumer, org.apache.hc.core5.http.nio.AsyncResponseConsumer<SseResponse>, org.apache.hc.core5.http.nio.ResourceHolder

public class CustomSseAsyncConsumer
extends org.apache.hc.client5.http.async.methods.AbstractCharResponseConsumer<SseResponse>

Author:

luna

Description:

Field Summary

Fields inherited from class org.apache.hc.core5.http.nio.entity.AbstractCharDataConsumer

DEF_BUF_SIZE

Constructor Summary

Constructors

Constructor	Description
CustomSseAsyncConsumer()
CustomSseAsyncConsumer(AbstactEventFutureCallback<SseResponse,Event> callback)
CustomSseAsyncConsumer(Integer capacity, AbstactEventFutureCallback<SseResponse,Event> callback, Integer timeWait)
CustomSseAsyncConsumer(org.apache.hc.core5.concurrent.FutureCallback<Event> listener)

Method Summary

Modifier and Type	Method	Description
protected SseResponse	buildResult()
protected int	capacityIncrement()
protected void	data(CharBuffer data, boolean endOfStream)
void	failed(Exception cause)
void	releaseResources()
protected void	start(org.apache.hc.core5.http.HttpResponse response, org.apache.hc.core5.http.ContentType contentType)

Methods inherited from class org.apache.hc.client5.http.async.methods.AbstractCharResponseConsumer

completed, consumeResponse, informationResponse

Methods inherited from class org.apache.hc.core5.http.nio.entity.AbstractCharDataConsumer

consume, setCharset, streamEnd, updateCapacity

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hc.core5.http.nio.AsyncDataConsumer

consume, streamEnd, updateCapacity

Constructor Details

CustomSseAsyncConsumer

public CustomSseAsyncConsumer(AbstactEventFutureCallback<SseResponse,Event> callback)

CustomSseAsyncConsumer

public CustomSseAsyncConsumer(Integer capacity,
 AbstactEventFutureCallback<SseResponse,Event> callback,
 Integer timeWait)

CustomSseAsyncConsumer

public CustomSseAsyncConsumer()

CustomSseAsyncConsumer

public CustomSseAsyncConsumer(org.apache.hc.core5.concurrent.FutureCallback<Event> listener)

Method Details

start

protected void start(org.apache.hc.core5.http.HttpResponse response,
 org.apache.hc.core5.http.ContentType contentType)
              throws org.apache.hc.core5.http.HttpException,
IOException

Specified by:

start in class org.apache.hc.client5.http.async.methods.AbstractCharResponseConsumer<SseResponse>

Throws:

org.apache.hc.core5.http.HttpException

IOException

capacityIncrement

protected int capacityIncrement()

Specified by:

capacityIncrement in class org.apache.hc.core5.http.nio.entity.AbstractCharDataConsumer

data

protected void data(CharBuffer data,
 boolean endOfStream)
             throws IOException

Specified by:

data in class org.apache.hc.core5.http.nio.entity.AbstractCharDataConsumer

Throws:

IOException

buildResult

protected SseResponse buildResult()

Specified by:

buildResult in class org.apache.hc.client5.http.async.methods.AbstractCharResponseConsumer<SseResponse>

releaseResources

public void releaseResources()

failed

public void failed(Exception cause)

Specified by:

failed in interface org.apache.hc.core5.http.nio.AsyncResponseConsumer<SseResponse>

Overrides:

failed in class org.apache.hc.client5.http.async.methods.AbstractCharResponseConsumer<SseResponse>