导航菜单

页面标题

页面副标题

SpeedCash v6.5.1482 - ServerStreamTracer.java 源代码

正在查看: SpeedCash v6.5.1482 应用的 ServerStreamTracer.java JAVA 源代码文件

本页面展示 JAVA 反编译生成的源代码文件,支持语法高亮显示。 仅供安全研究与技术分析使用,严禁用于任何非法用途。请遵守相关法律法规。


package io.grpc;

import javax.annotation.Nullable;
import javax.annotation.concurrent.ThreadSafe;

@ExperimentalApi("https://github.com/grpc/grpc-java/issues/2861")
@ThreadSafe
public abstract class ServerStreamTracer extends StreamTracer {

    public static abstract class Factory {
        public abstract ServerStreamTracer newServerStreamTracer(String str, Metadata metadata);
    }

    public static abstract class ServerCallInfo<ReqT, RespT> {
        public abstract Attributes getAttributes();

        @Nullable
        public abstract String getAuthority();

        public abstract MethodDescriptor<ReqT, RespT> getMethodDescriptor();
    }

    @Deprecated
    public static final class a<ReqT, RespT> extends ForwardingServerCall<ReqT, RespT> {
        public final ServerCallInfo<ReqT, RespT> a;

        public a(ServerCallInfo<ReqT, RespT> serverCallInfo) {
            this.a = serverCallInfo;
        }

        public static <ReqT, RespT> a<ReqT, RespT> b(ServerCallInfo<ReqT, RespT> serverCallInfo) {
            return new a<>(serverCallInfo);
        }

        @Override
        public ServerCall<ReqT, RespT> delegate() {
            throw new UnsupportedOperationException();
        }

        @Override
        public Attributes getAttributes() {
            return this.a.getAttributes();
        }

        @Override
        public String getAuthority() {
            return this.a.getAuthority();
        }

        @Override
        public MethodDescriptor<ReqT, RespT> getMethodDescriptor() {
            return this.a.getMethodDescriptor();
        }

        @Override
        public boolean isCancelled() {
            return false;
        }

        @Override
        public boolean isReady() {
            return false;
        }
    }

    public Context filterContext(Context context) {
        return context;
    }

    @Deprecated
    public void serverCallStarted(ServerCall<?, ?> serverCall) {
    }

    public void serverCallStarted(ServerCallInfo<?, ?> serverCallInfo) {
        serverCallStarted(a.b(serverCallInfo));
    }
}