diff --git a/httpclient5-sse/src/test/java/org/apache/hc/client5/http/sse/DefaultEventSourceIntegrationTest.java b/httpclient5-sse/src/test/java/org/apache/hc/client5/http/sse/DefaultEventSourceIntegrationTest.java index eb3a77d961..2fcbcd9a36 100644 --- a/httpclient5-sse/src/test/java/org/apache/hc/client5/http/sse/DefaultEventSourceIntegrationTest.java +++ b/httpclient5-sse/src/test/java/org/apache/hc/client5/http/sse/DefaultEventSourceIntegrationTest.java @@ -40,6 +40,7 @@ import java.util.concurrent.TimeUnit; import org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient; +import org.apache.hc.client5.http.protocol.HttpClientContext; import org.apache.hc.client5.http.sse.impl.SseParser; import org.apache.hc.core5.concurrent.FutureCallback; import org.apache.hc.core5.function.Supplier; @@ -51,7 +52,6 @@ import org.apache.hc.core5.http.nio.AsyncRequestProducer; import org.apache.hc.core5.http.nio.AsyncResponseConsumer; import org.apache.hc.core5.http.nio.HandlerFactory; -import org.apache.hc.core5.http.protocol.BasicHttpContext; import org.apache.hc.core5.http.protocol.HttpContext; import org.apache.hc.core5.io.CloseMode; import org.apache.hc.core5.reactor.IOReactorStatus; @@ -102,10 +102,11 @@ public void onClosed() { final AsyncResponseConsumer c = fake.lastConsumer; assertNotNull(c, "consumer captured"); + final HttpContext context = HttpClientContext.create(); c.consumeResponse( new BasicHttpResponse(HttpStatus.SC_OK, "OK"), new TestEntityDetails("text/event-stream"), - new BasicHttpContext(), // FIX: concrete HttpContext + context, new FutureCallback() { @Override public void completed(final Void result) {