diff --git a/saluki-core/src/main/java/com/quancheng/saluki/core/grpc/client/internal/stream/CallToStreamObserverAdapter.java b/saluki-core/src/main/java/com/quancheng/saluki/core/grpc/client/internal/stream/CallToStreamObserverAdapter.java index d7e9d377..fc05310e 100644 --- a/saluki-core/src/main/java/com/quancheng/saluki/core/grpc/client/internal/stream/CallToStreamObserverAdapter.java +++ b/saluki-core/src/main/java/com/quancheng/saluki/core/grpc/client/internal/stream/CallToStreamObserverAdapter.java @@ -13,8 +13,6 @@ */ package com.quancheng.saluki.core.grpc.client.internal.stream; -import javax.annotation.Nullable; - import io.grpc.ClientCall; import io.grpc.stub.ClientCallStreamObserver; @@ -93,10 +91,4 @@ public void setMessageCompression(boolean enable) { call.setMessageCompression(enable); } - @Override - public void cancel(@Nullable String message, @Nullable Throwable cause) { - call.cancel(message, cause); - } - - }