[polish] code cleanup

Author: je-ik

beam/tools/src/main/java/cz/o2/proxima/beam/tools/groovy/RemoteConsumer.java

@@ -103,7 +103,7 @@ public StreamObserver<Item> collect(StreamObserver<Response> responseObserver) {
       unterminatedCalls.add(terminateFuture);
       // send initial status to client
       responseObserver.onNext(Response.newBuilder().setStatus(CONTINUE).build());
-      return new StreamObserver<Item>() {
+      return new StreamObserver<>() {
 
         List<Item> received = new ArrayList<>();
 

direct/ingest-server/src/main/java/cz/o2/proxima/direct/server/RetrieveService.java

@@ -325,7 +325,7 @@ public void multifetch(
     for (GetRequest getRequest : request.getGetRequestList()) {
       get(
           getRequest.toBuilder().setTransactionId(request.getTransactionId()).build(),
-          new StreamObserver<GetResponse>() {
+          new StreamObserver<>() {
             @Override
             public void onNext(GetResponse getResponse) {
               response.addGetResponse(getResponse);
@@ -348,7 +348,7 @@ public void onCompleted() {}
       for (ListRequest listRequest : request.getListRequestList()) {
         listAttributes(
             listRequest.toBuilder().setTransactionId(request.getTransactionId()).build(),
-            new StreamObserver<ListResponse>() {
+            new StreamObserver<>() {
               @Override
               public void onNext(ListResponse listResponse) {
                 response.addListResponse(listResponse);