what-the-bank/sources/io/grpc/ServerStreamTracer.java

77 lines
2.7 KiB
Java
Raw Permalink Normal View History

2024-07-27 18:17:47 +07:00
package io.grpc;
/* loaded from: classes6.dex */
public abstract class ServerStreamTracer extends StreamTracer {
/* loaded from: classes6.dex */
public static abstract class Factory {
public abstract ServerStreamTracer newServerStreamTracer(String str, Metadata metadata);
}
/* loaded from: classes6.dex */
public static abstract class ServerCallInfo<ReqT, RespT> {
public abstract Attributes getAttributes();
public abstract String getAuthority();
public abstract MethodDescriptor<ReqT, RespT> getMethodDescriptor();
}
public Context filterContext(Context context) {
return context;
}
@Deprecated
public void serverCallStarted(ServerCall<?, ?> serverCall) {
}
public void serverCallStarted(ServerCallInfo<?, ?> serverCallInfo) {
serverCallStarted(ReadOnlyServerCall.create(serverCallInfo));
}
@Deprecated
/* loaded from: classes6.dex */
static final class ReadOnlyServerCall<ReqT, RespT> extends ForwardingServerCall<ReqT, RespT> {
private final ServerCallInfo<ReqT, RespT> callInfo;
@Override // io.grpc.ForwardingServerCall, io.grpc.PartialForwardingServerCall, io.grpc.ServerCall
public final boolean isCancelled() {
return false;
}
@Override // io.grpc.ForwardingServerCall, io.grpc.PartialForwardingServerCall, io.grpc.ServerCall
public final boolean isReady() {
return false;
}
/* JADX INFO: Access modifiers changed from: private */
public static <ReqT, RespT> ReadOnlyServerCall<ReqT, RespT> create(ServerCallInfo<ReqT, RespT> serverCallInfo) {
return new ReadOnlyServerCall<>(serverCallInfo);
}
private ReadOnlyServerCall(ServerCallInfo<ReqT, RespT> serverCallInfo) {
this.callInfo = serverCallInfo;
}
@Override // io.grpc.ServerCall
public final MethodDescriptor<ReqT, RespT> getMethodDescriptor() {
return this.callInfo.getMethodDescriptor();
}
@Override // io.grpc.ForwardingServerCall, io.grpc.PartialForwardingServerCall, io.grpc.ServerCall
public final Attributes getAttributes() {
return this.callInfo.getAttributes();
}
@Override // io.grpc.ForwardingServerCall, io.grpc.PartialForwardingServerCall, io.grpc.ServerCall
public final String getAuthority() {
return this.callInfo.getAuthority();
}
@Override // io.grpc.ForwardingServerCall, io.grpc.PartialForwardingServerCall
protected final ServerCall<ReqT, RespT> delegate() {
throw new UnsupportedOperationException();
}
}
}