import io.reactivex.rxjava3.core.Completable;
import io.reactivex.rxjava3.core.Single;
import java.util.List;
-import org.apache.hc.client5.http.async.methods.SimpleHttpRequest;
import org.apache.hc.client5.http.async.methods.SimpleHttpRequests;
import org.apache.hc.client5.http.async.methods.SimpleHttpResponse;
import org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient;
}
private Completable notify(final String url, final String payload) {
- final SimpleHttpRequest request = SimpleHttpRequests.post(url);
+ final var request = SimpleHttpRequests.post(url);
request.setBody(payload, ContentType.APPLICATION_JSON);
request.setHeader(HttpHeaders.AUTHORIZATION, authHeader);
return Single.fromFuture(httpClient.execute(request, null))
}
private static Completable validatePost(final SimpleHttpResponse response) {
- final String statusLine = new StatusLine(response).toString();
+ final var statusLine = new StatusLine(response).toString();
final String entity;
final int code = response.getCode();
if (code == HttpStatus.SC_OK || code == HttpStatus.SC_ACCEPTED) {