From 723caac7490b83eb6df5dc19e2b41b94ee8ae7d1 Mon Sep 17 00:00:00 2001
From: Krzysztof Witukiewicz <krzysztof.witukiewicz@mgm-tp.com>
Date: Mon, 17 Feb 2025 15:03:12 +0100
Subject: [PATCH] OZG-7608 OZG-7729 Rename generic types to meet conventions
---
.../common/grpc/GrpcResponseBatchStreamer.java | 18 +++++++++---------
.../common/grpc/GrpcResponseBuilder.java | 6 +++---
2 files changed, 12 insertions(+), 12 deletions(-)
diff --git a/vorgang-manager-server/src/main/java/de/ozgcloud/vorgang/common/grpc/GrpcResponseBatchStreamer.java b/vorgang-manager-server/src/main/java/de/ozgcloud/vorgang/common/grpc/GrpcResponseBatchStreamer.java
index bf1914ecf..675fec546 100644
--- a/vorgang-manager-server/src/main/java/de/ozgcloud/vorgang/common/grpc/GrpcResponseBatchStreamer.java
+++ b/vorgang-manager-server/src/main/java/de/ozgcloud/vorgang/common/grpc/GrpcResponseBatchStreamer.java
@@ -28,30 +28,30 @@ import java.util.function.Supplier;
import io.grpc.stub.StreamObserver;
import lombok.Setter;
-public class GrpcResponseBatchStreamer<ElemType, ResType> {
+public class GrpcResponseBatchStreamer<E, T> {
public static final int DEFAULT_BATCH_SIZE = 100;
@Setter
private int batchSize = DEFAULT_BATCH_SIZE;
- private final Supplier<GrpcResponseBuilder<ElemType, ResType>> responseBuilderSupplier;
- private final StreamObserver<ResType> responseObserver;
- private GrpcResponseBuilder<ElemType, ResType> responseBuilder;
+ private final Supplier<GrpcResponseBuilder<E, T>> responseBuilderSupplier;
+ private final StreamObserver<T> responseObserver;
+ private GrpcResponseBuilder<E, T> responseBuilder;
- public static <ElemType, ResType> GrpcResponseBatchStreamer<ElemType, ResType> create(Supplier<GrpcResponseBuilder<ElemType, ResType>> responseBuilderSupplier,
- StreamObserver<ResType> responseObserver) {
+ public static <E, T> GrpcResponseBatchStreamer<E, T> create(Supplier<GrpcResponseBuilder<E, T>> responseBuilderSupplier,
+ StreamObserver<T> responseObserver) {
return new GrpcResponseBatchStreamer<>(responseBuilderSupplier, responseObserver);
}
- private GrpcResponseBatchStreamer(Supplier<GrpcResponseBuilder<ElemType, ResType>> responseBuilderSupplier,
- StreamObserver<ResType> responseObserver) {
+ private GrpcResponseBatchStreamer(Supplier<GrpcResponseBuilder<E, T>> responseBuilderSupplier,
+ StreamObserver<T> responseObserver) {
this.responseBuilderSupplier = responseBuilderSupplier;
this.responseObserver = responseObserver;
responseBuilder = responseBuilderSupplier.get();
}
- public void send(ElemType element) {
+ public void send(E element) {
responseBuilder.addElement(element);
if (batchIsFull()) {
sendResponse();
diff --git a/vorgang-manager-server/src/main/java/de/ozgcloud/vorgang/common/grpc/GrpcResponseBuilder.java b/vorgang-manager-server/src/main/java/de/ozgcloud/vorgang/common/grpc/GrpcResponseBuilder.java
index 0cfe4aeb4..1651ab880 100644
--- a/vorgang-manager-server/src/main/java/de/ozgcloud/vorgang/common/grpc/GrpcResponseBuilder.java
+++ b/vorgang-manager-server/src/main/java/de/ozgcloud/vorgang/common/grpc/GrpcResponseBuilder.java
@@ -23,11 +23,11 @@
*/
package de.ozgcloud.vorgang.common.grpc;
-public interface GrpcResponseBuilder<ElemType, ResType> {
+public interface GrpcResponseBuilder<E, T> {
int getElementCount();
- void addElement(ElemType elem);
+ void addElement(E elem);
- ResType build();
+ T build();
}
--
GitLab