remove shutdown() from TransportWithDisconnectReason

Author: AgraVator

core/src/main/java/io/grpc/internal/KeepAliveManager.java

@@ -272,15 +272,6 @@ public static final class ClientKeepAlivePinger implements KeepAlivePinger {
     @ThreadSafe
     public interface TransportWithDisconnectReason extends ClientTransport {
 
-      /**
-       * Initiates an orderly shutdown of the transport.  Existing streams continue, but the
-       * transport will not own any new streams.  New streams will either fail (once
-       * {@link ManagedClientTransport.Listener#transportShutdown} callback called), or be
-       * transferred off this transport (in which case they may succeed).  This method may only be
-       * called once.
-       */
-      void shutdown(Status reason, DisconnectError disconnectError);
-
       /**
        * Initiates a forceful shutdown in which preexisting and new calls are closed. Existing calls
        * should be closed with the provided {@code reason} and {@code disconnectError}.

netty/src/main/java/io/grpc/netty/NettyClientTransport.java

@@ -350,11 +350,6 @@ public void operationComplete(ChannelFuture future) throws Exception {
 
   @Override
   public void shutdown(Status reason) {
-    shutdown(reason, SimpleDisconnectError.SUBCHANNEL_SHUTDOWN);
-  }
-
-  @Override
-  public void shutdown(Status reason, DisconnectError disconnectError) {
     // start() could have failed
     if (channel == null) {
       return;

okhttp/src/main/java/io/grpc/okhttp/OkHttpClientTransport.java

@@ -987,18 +987,13 @@ int getOverridenPort() {
 
   @Override
   public void shutdown(Status reason) {
-    shutdown(reason, SimpleDisconnectError.SUBCHANNEL_SHUTDOWN);
-  }
-
-  @Override
-  public void shutdown(Status reason, DisconnectError disconnectError) {
     synchronized (lock) {
       if (goAwayStatus != null) {
         return;
       }
 
       goAwayStatus = reason;
-      listener.transportShutdown(goAwayStatus, disconnectError);
+      listener.transportShutdown(goAwayStatus, SimpleDisconnectError.SUBCHANNEL_SHUTDOWN);
       stopIfNecessary();
     }
   }
@@ -1010,7 +1005,7 @@ public void shutdownNow(Status reason) {
 
   @Override
   public void shutdownNow(Status reason, DisconnectError disconnectError) {
-    shutdown(reason, disconnectError);
+    shutdown(reason);
     synchronized (lock) {
       Iterator<Map.Entry<Integer, OkHttpClientStream>> it = streams.entrySet().iterator();
       while (it.hasNext()) {