SpeedCash v6.5.1482 - ClientStreamTracer.java 源代码

package io.grpc;

import com.google.common.base.MoreObjects;
import com.google.common.base.Preconditions;
import javax.annotation.concurrent.ThreadSafe;

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

    public static abstract class Factory {
        public ClientStreamTracer newClientStreamTracer(StreamInfo streamInfo, Metadata metadata) {
            throw new UnsupportedOperationException("Not implemented");
        }
    }

    @ExperimentalApi("https://github.com/grpc/grpc-java/issues/2861")
    public static final class StreamInfo {
        public final CallOptions a;
        public final int b;
        public final boolean c;

        public static final class Builder {
            public CallOptions a = CallOptions.DEFAULT;
            public int b;
            public boolean c;

            public StreamInfo build() {
                return new StreamInfo(this.a, this.b, this.c);
            }

            public Builder setCallOptions(CallOptions callOptions) {
                this.a = (CallOptions) Preconditions.checkNotNull(callOptions, "callOptions cannot be null");
                return this;
            }

            public Builder setIsTransparentRetry(boolean z) {
                this.c = z;
                return this;
            }

            public Builder setPreviousAttempts(int i) {
                this.b = i;
                return this;
            }
        }

        public StreamInfo(CallOptions callOptions, int i, boolean z) {
            this.a = (CallOptions) Preconditions.checkNotNull(callOptions, "callOptions");
            this.b = i;
            this.c = z;
        }

        public static Builder newBuilder() {
            return new Builder();
        }

        public CallOptions getCallOptions() {
            return this.a;
        }

        public int getPreviousAttempts() {
            return this.b;
        }

        public boolean isTransparentRetry() {
            return this.c;
        }

        public Builder toBuilder() {
            return new Builder().setCallOptions(this.a).setPreviousAttempts(this.b).setIsTransparentRetry(this.c);
        }

        public String toString() {
            return MoreObjects.toStringHelper(this).add("callOptions", this.a).add("previousAttempts", this.b).add("isTransparentRetry", this.c).toString();
        }
    }

    public void inboundHeaders() {
    }

    public void inboundTrailers(Metadata metadata) {
    }

    public void outboundHeaders() {
    }

    public void streamCreated(Attributes attributes, Metadata metadata) {
    }
}