Ecosystem/haveno
Ecosystem/haveno
2
1
Fork 0
mirror of https://github.com/haveno-dex/haveno.git synced 2024-12-22 19:49:32 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

only send push notification if call stream not cancelled

Browse source
This commit is contained in:
woodser 2022-12-28 08:01:39 +00:00
parent c5f6aeb4cc
commit 9f8bd77c9e
1 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
daemon/src/main/java/bisq/daemon/grpc/GrpcNotificationsService.java
View file

@ -10,6 +10,7 @@ import bisq.proto.grpc.SendNotificationReply;
import bisq.proto.grpc.SendNotificationRequest; import bisq.proto.grpc.SendNotificationRequest;
import io.grpc.Context; import io.grpc.Context;
import io.grpc.ServerInterceptor; import io.grpc.ServerInterceptor;
import io.grpc.stub.ServerCallStreamObserver;
import io.grpc.stub.StreamObserver; import io.grpc.stub.StreamObserver;
import javax.inject.Inject; import javax.inject.Inject;
@ -80,9 +81,11 @@ class GrpcNotificationsService extends NotificationsImplBase {
@Override @Override
public void onMessage(@NonNull NotificationMessage message) { public void onMessage(@NonNull NotificationMessage message) {
if (!((ServerCallStreamObserver<NotificationMessage>) responseObserver).isCancelled()) {
responseObserver.onNext(message); responseObserver.onNext(message);
} }
} }
}
final ServerInterceptor[] interceptors() { final ServerInterceptor[] interceptors() {
Optional<ServerInterceptor> rateMeteringInterceptor = rateMeteringInterceptor(); Optional<ServerInterceptor> rateMeteringInterceptor = rateMeteringInterceptor();