77 lines
2.7 KiB
Java
77 lines
2.7 KiB
Java
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();
|
|
}
|
|
}
|
|
}
|