Skip to content
Snippets Groups Projects

OZG-7573 OZG-7991 Notify requestObserver about error in StreamingFileSender

Merged Krzysztof Witukiewicz requested to merge OZG-7573-files-weiterleitung-bug into main
4 files
+ 17
87
Compare changes
  • Side-by-side
  • Inline
Files
4
@@ -27,7 +27,6 @@ import java.io.InputStream;
@@ -27,7 +27,6 @@ import java.io.InputStream;
import java.util.function.BiFunction;
import java.util.function.BiFunction;
import java.util.function.Function;
import java.util.function.Function;
import de.ozgcloud.common.errorhandling.TechnicalException;
import io.grpc.stub.CallStreamObserver;
import io.grpc.stub.CallStreamObserver;
import io.grpc.stub.StreamObserver;
import io.grpc.stub.StreamObserver;
import lombok.extern.log4j.Log4j2;
import lombok.extern.log4j.Log4j2;
@@ -63,16 +62,4 @@ class StreamExclusiveFileSender<Q, S> extends StreamingFileSender<Q, S> {
@@ -63,16 +62,4 @@ class StreamExclusiveFileSender<Q, S> extends StreamingFileSender<Q, S> {
protected CallStreamObserver<Q> getRequestObserver() {
protected CallStreamObserver<Q> getRequestObserver() {
return requestObserver;
return requestObserver;
}
}
@Override
public void cancelOnTimeout() {
super.cancelOnTimeout();
requestObserver.onError(new TechnicalException("Timeout on waiting for upload."));
}
@Override
public void cancelOnError(Throwable t) {
super.cancelOnError(t);
requestObserver.onError(t);
}
}
}
Loading