Skip to content
Snippets Groups Projects
Commit 723caac7 authored by Krzysztof Witukiewicz's avatar Krzysztof Witukiewicz
Browse files

OZG-7608 OZG-7729 Rename generic types to meet conventions

parent e753f326
No related branches found
No related tags found
1 merge request!17OZG-7608 OZG-7729 gRPC endpoint for deleted Vorgaenge
...@@ -28,30 +28,30 @@ import java.util.function.Supplier; ...@@ -28,30 +28,30 @@ import java.util.function.Supplier;
import io.grpc.stub.StreamObserver; import io.grpc.stub.StreamObserver;
import lombok.Setter; import lombok.Setter;
public class GrpcResponseBatchStreamer<ElemType, ResType> { public class GrpcResponseBatchStreamer<E, T> {
public static final int DEFAULT_BATCH_SIZE = 100; public static final int DEFAULT_BATCH_SIZE = 100;
@Setter @Setter
private int batchSize = DEFAULT_BATCH_SIZE; private int batchSize = DEFAULT_BATCH_SIZE;
private final Supplier<GrpcResponseBuilder<ElemType, ResType>> responseBuilderSupplier; private final Supplier<GrpcResponseBuilder<E, T>> responseBuilderSupplier;
private final StreamObserver<ResType> responseObserver; private final StreamObserver<T> responseObserver;
private GrpcResponseBuilder<ElemType, ResType> responseBuilder; private GrpcResponseBuilder<E, T> responseBuilder;
public static <ElemType, ResType> GrpcResponseBatchStreamer<ElemType, ResType> create(Supplier<GrpcResponseBuilder<ElemType, ResType>> responseBuilderSupplier, public static <E, T> GrpcResponseBatchStreamer<E, T> create(Supplier<GrpcResponseBuilder<E, T>> responseBuilderSupplier,
StreamObserver<ResType> responseObserver) { StreamObserver<T> responseObserver) {
return new GrpcResponseBatchStreamer<>(responseBuilderSupplier, responseObserver); return new GrpcResponseBatchStreamer<>(responseBuilderSupplier, responseObserver);
} }
private GrpcResponseBatchStreamer(Supplier<GrpcResponseBuilder<ElemType, ResType>> responseBuilderSupplier, private GrpcResponseBatchStreamer(Supplier<GrpcResponseBuilder<E, T>> responseBuilderSupplier,
StreamObserver<ResType> responseObserver) { StreamObserver<T> responseObserver) {
this.responseBuilderSupplier = responseBuilderSupplier; this.responseBuilderSupplier = responseBuilderSupplier;
this.responseObserver = responseObserver; this.responseObserver = responseObserver;
responseBuilder = responseBuilderSupplier.get(); responseBuilder = responseBuilderSupplier.get();
} }
public void send(ElemType element) { public void send(E element) {
responseBuilder.addElement(element); responseBuilder.addElement(element);
if (batchIsFull()) { if (batchIsFull()) {
sendResponse(); sendResponse();
......
...@@ -23,11 +23,11 @@ ...@@ -23,11 +23,11 @@
*/ */
package de.ozgcloud.vorgang.common.grpc; package de.ozgcloud.vorgang.common.grpc;
public interface GrpcResponseBuilder<ElemType, ResType> { public interface GrpcResponseBuilder<E, T> {
int getElementCount(); int getElementCount();
void addElement(ElemType elem); void addElement(E elem);
ResType build(); T build();
} }
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment