Skip to content
Snippets Groups Projects
Commit d021a5d0 authored by Felix Reichenbach's avatar Felix Reichenbach
Browse files

OZG-7573 set public methods synchronized in EingangStubReceiverStreamObserver

parent ee192e1d
No related branches found
No related tags found
1 merge request!9Ozg 7573 forward vorgang
...@@ -172,7 +172,7 @@ public class EingangStubReceiverStreamObserver implements StreamObserver<GrpcRou ...@@ -172,7 +172,7 @@ public class EingangStubReceiverStreamObserver implements StreamObserver<GrpcRou
} }
@Override @Override
public void onError(Throwable t) { public synchronized void onError(Throwable t) {
LOG.error("Error happened. Receiving stream closed.", t); LOG.error("Error happened. Receiving stream closed.", t);
closeOutputPipe(); closeOutputPipe();
closeInputPipe(); closeInputPipe();
...@@ -187,7 +187,7 @@ public class EingangStubReceiverStreamObserver implements StreamObserver<GrpcRou ...@@ -187,7 +187,7 @@ public class EingangStubReceiverStreamObserver implements StreamObserver<GrpcRou
} }
@Override @Override
public void onCompleted() { public synchronized void onCompleted() {
formDataConsumer.accept(assembleFormData()); formDataConsumer.accept(assembleFormData());
responseConsumer.accept(GrpcRouteForwardingResponse.getDefaultInstance()); responseConsumer.accept(GrpcRouteForwardingResponse.getDefaultInstance());
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment