Skip to content

Instantly share code, notes, and snippets.

@apoorvparijat
Created April 11, 2023 14:26
Show Gist options
  • Select an option

  • Save apoorvparijat/8a2c6c7d0ffe08d931630202b2c5942a to your computer and use it in GitHub Desktop.

Select an option

Save apoorvparijat/8a2c6c7d0ffe08d931630202b2c5942a to your computer and use it in GitHub Desktop.
Completion handler
import org.asynchttpclient.*;
import org.asynchttpclient.AsyncHandler;
import org.asynchttpclient.HttpResponseBodyPart;
import org.asynchttpclient.HttpResponseHeaders;
import org.asynchttpclient.HttpResponseStatus;
public class MyAsyncHandler implements AsyncHandler<String> {
private final StringBuilder responseBodyBuilder = new StringBuilder();
@Override
public State onStatusReceived(HttpResponseStatus status) throws Exception {
return State.CONTINUE;
}
@Override
public State onHeadersReceived(HttpResponseHeaders headers) throws Exception {
return State.CONTINUE;
}
@Override
public State onBodyPartReceived(HttpResponseBodyPart bodyPart) throws Exception {
responseBodyBuilder.append(new String(bodyPart.getBodyPartBytes()));
return State.CONTINUE;
}
@Override
public String onCompleted() throws Exception {
return responseBodyBuilder.toString();
}
@Override
public void onThrowable(Throwable t) {
t.printStackTrace();
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment