You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hc.apache.org by gg...@apache.org on 2020/11/24 14:22:40 UTC
[httpcomponents-client] 03/06: Add missing @Override.
This is an automated email from the ASF dual-hosted git repository.
ggregory pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/httpcomponents-client.git
commit 400771a1a7caa61affcdad89a6b5f96fff8652a7
Author: Gary Gregory <ga...@gmail.com>
AuthorDate: Mon Nov 23 11:17:54 2020 -0500
Add missing @Override.
---
.../client5/http/impl/cache/TestHttpByteArrayCacheEntrySerializer.java | 1 +
.../hc/client5/testing/async/AbstractHttpReactiveFundamentalsTest.java | 3 +++
2 files changed, 4 insertions(+)
diff --git a/httpclient5-cache/src/test/java/org/apache/hc/client5/http/impl/cache/TestHttpByteArrayCacheEntrySerializer.java b/httpclient5-cache/src/test/java/org/apache/hc/client5/http/impl/cache/TestHttpByteArrayCacheEntrySerializer.java
index 4c333e7..dacc3a9 100644
--- a/httpclient5-cache/src/test/java/org/apache/hc/client5/http/impl/cache/TestHttpByteArrayCacheEntrySerializer.java
+++ b/httpclient5-cache/src/test/java/org/apache/hc/client5/http/impl/cache/TestHttpByteArrayCacheEntrySerializer.java
@@ -366,6 +366,7 @@ public class TestHttpByteArrayCacheEntrySerializer {
final HttpCacheStorageEntry testEntry = cacheObjectValues.toEntry();
final HttpByteArrayCacheEntrySerializer testSerializer = new HttpByteArrayCacheEntrySerializer() {
+ @Override
protected AbstractMessageWriter<SimpleHttpResponse> makeHttpResponseWriter(final SessionOutputBuffer outputBuffer) {
return throwyHttpWriter;
}
diff --git a/httpclient5-testing/src/test/java/org/apache/hc/client5/testing/async/AbstractHttpReactiveFundamentalsTest.java b/httpclient5-testing/src/test/java/org/apache/hc/client5/testing/async/AbstractHttpReactiveFundamentalsTest.java
index f20ea55..e4814f1 100644
--- a/httpclient5-testing/src/test/java/org/apache/hc/client5/testing/async/AbstractHttpReactiveFundamentalsTest.java
+++ b/httpclient5-testing/src/test/java/org/apache/hc/client5/testing/async/AbstractHttpReactiveFundamentalsTest.java
@@ -158,6 +158,7 @@ public abstract class AbstractHttpReactiveFundamentalsTest<T extends CloseableHt
.build();
final ReactiveResponseConsumer consumer = new ReactiveResponseConsumer(new FutureCallback<Message<HttpResponse, Publisher<ByteBuffer>>>() {
+ @Override
public void completed(final Message<HttpResponse, Publisher<ByteBuffer>> result) {
final Flowable<ByteBuffer> flowable = Flowable.fromPublisher(result.getBody())
.observeOn(Schedulers.io()); // Stream the data on an RxJava scheduler, not a client thread
@@ -169,7 +170,9 @@ public abstract class AbstractHttpReactiveFundamentalsTest<T extends CloseableHt
}
});
}
+ @Override
public void failed(final Exception ex) { }
+ @Override
public void cancelled() { }
});
httpclient.execute(request, consumer, HttpClientContext.create(), null);