fix diamonds

Author: slandelle

api/src/main/java/org/asynchttpclient/DefaultAsyncHttpClient.java

@@ -232,7 +232,7 @@ public <T> ListenableFuture<T> executeRequest(Request request, AsyncHandler<T> h
  return httpProvider.execute(request, handler);
 
  } else {
- FilterContext<T> fc = new FilterContext.FilterContextBuilder<>().asyncHandler(handler).request(request).build();
+ FilterContext<T> fc = new FilterContext.FilterContextBuilder<T>().asyncHandler(handler).request(request).build();
  try {
  fc = preProcessRequest(fc);
  } catch (Exception e) {

api/src/test/java/org/asynchttpclient/async/FilterTest.java

@@ -140,7 +140,7 @@ public <T> FilterContext<T> filter(FilterContext<T> ctx) throws FilterException
 
  if (replay.getAndSet(false)) {
  Request request = new RequestBuilder(ctx.getRequest()).addHeader("X-Replay", "true").build();
- return new FilterContext.FilterContextBuilder<>().asyncHandler(ctx.getAsyncHandler()).request(request).replayRequest(true).build();
+ return new FilterContext.FilterContextBuilder<T>().asyncHandler(ctx.getAsyncHandler()).request(request).replayRequest(true).build();
  }
  return ctx;
  }
@@ -166,7 +166,7 @@ public <T> FilterContext<T> filter(FilterContext<T> ctx) throws FilterException
 
  if (ctx.getResponseStatus() != null && ctx.getResponseStatus().getStatusCode() == 200 && replay.getAndSet(false)) {
  Request request = new RequestBuilder(ctx.getRequest()).addHeader("X-Replay", "true").build();
- return new FilterContext.FilterContextBuilder<>().asyncHandler(ctx.getAsyncHandler()).request(request).replayRequest(true).build();
+ return new FilterContext.FilterContextBuilder<T>().asyncHandler(ctx.getAsyncHandler()).request(request).replayRequest(true).build();
  }
  return ctx;
  }
@@ -193,7 +193,7 @@ public <T> FilterContext<T> filter(FilterContext<T> ctx) throws FilterException
  if (ctx.getResponseHeaders() != null && ctx.getResponseHeaders().getHeaders().getFirstValue("Ping").equals("Pong") && replay.getAndSet(false)) {
 
  Request request = new RequestBuilder(ctx.getRequest()).addHeader("Ping", "Pong").build();
- return new FilterContext.FilterContextBuilder<>().asyncHandler(ctx.getAsyncHandler()).request(request).replayRequest(true).build();
+ return new FilterContext.FilterContextBuilder<T>().asyncHandler(ctx.getAsyncHandler()).request(request).replayRequest(true).build();
  }
  return ctx;
  }

providers/netty3/src/test/java/org/asynchttpclient/providers/netty3/NettyRequestThrottleTimeoutTest.java

@@ -85,7 +85,7 @@ public void testRequestTimeout() throws IOException {
 
  try (AsyncHttpClient client = getAsyncHttpClient(new AsyncHttpClientConfig.Builder().setMaxConnections(1).build())) {
  final CountDownLatch latch = new CountDownLatch(samples);
- final List<Exception> tooManyConnections = Collections.synchronizedList(new ArrayList<>(2));
+ final List<Exception> tooManyConnections = Collections.synchronizedList(new ArrayList<Exception>(2));
 
  for (int i = 0; i < samples; i++) {
  new Thread(new Runnable() {