what-the-bank/sources/io/grpc/internal/ForwardingManagedChannel.java

79 lines
2.4 KiB
Java
Raw Permalink Normal View History

2024-07-27 18:17:47 +07:00
package io.grpc.internal;
import com.google.common.base.MoreObjects;
import io.grpc.CallOptions;
import io.grpc.ClientCall;
import io.grpc.ConnectivityState;
import io.grpc.ManagedChannel;
import io.grpc.MethodDescriptor;
import java.util.concurrent.TimeUnit;
/* loaded from: classes6.dex */
abstract class ForwardingManagedChannel extends ManagedChannel {
private final ManagedChannel delegate;
/* JADX INFO: Access modifiers changed from: package-private */
public ForwardingManagedChannel(ManagedChannel managedChannel) {
this.delegate = managedChannel;
}
@Override // io.grpc.ManagedChannel
public ManagedChannel shutdown() {
return this.delegate.shutdown();
}
@Override // io.grpc.ManagedChannel
public boolean isShutdown() {
return this.delegate.isShutdown();
}
@Override // io.grpc.ManagedChannel
public boolean isTerminated() {
return this.delegate.isTerminated();
}
@Override // io.grpc.ManagedChannel
public ManagedChannel shutdownNow() {
return this.delegate.shutdownNow();
}
@Override // io.grpc.ManagedChannel
public boolean awaitTermination(long j, TimeUnit timeUnit) throws InterruptedException {
return this.delegate.awaitTermination(j, timeUnit);
}
@Override // io.grpc.Channel
public <RequestT, ResponseT> ClientCall<RequestT, ResponseT> newCall(MethodDescriptor<RequestT, ResponseT> methodDescriptor, CallOptions callOptions) {
return this.delegate.newCall(methodDescriptor, callOptions);
}
@Override // io.grpc.Channel
public String authority() {
return this.delegate.authority();
}
@Override // io.grpc.ManagedChannel
public ConnectivityState getState(boolean z) {
return this.delegate.getState(z);
}
@Override // io.grpc.ManagedChannel
public void notifyWhenStateChanged(ConnectivityState connectivityState, Runnable runnable) {
this.delegate.notifyWhenStateChanged(connectivityState, runnable);
}
@Override // io.grpc.ManagedChannel
public void resetConnectBackoff() {
this.delegate.resetConnectBackoff();
}
@Override // io.grpc.ManagedChannel
public void enterIdle() {
this.delegate.enterIdle();
}
public String toString() {
return MoreObjects.toStringHelper(this).add("delegate", this.delegate).toString();
}
}