75 lines
3.0 KiB
Java
75 lines
3.0 KiB
Java
|
package o;
|
||
|
|
|
||
|
|
import io.grpc.CallOptions;
|
||
|
|
import io.grpc.Channel;
|
||
|
|
import io.grpc.MethodDescriptor;
|
||
|
|
import io.grpc.protobuf.lite.ProtoLiteUtils;
|
||
|
|
import io.grpc.stub.AbstractAsyncStub;
|
||
|
|
import io.grpc.stub.AbstractStub;
|
||
|
|
|
||
|
|
/* loaded from: classes2.dex */
|
||
|
|
public final class GMq {
|
||
|
|
private static volatile MethodDescriptor<mnR, C1151WuV> b;
|
||
|
|
private static volatile MethodDescriptor<C0993Tei, ZMV> e;
|
||
|
|
|
||
|
|
private GMq() {
|
||
|
|
}
|
||
|
|
|
||
|
|
public static MethodDescriptor<mnR, C1151WuV> d() {
|
||
|
|
MethodDescriptor<mnR, C1151WuV> methodDescriptor;
|
||
|
|
MethodDescriptor<mnR, C1151WuV> methodDescriptor2 = b;
|
||
|
|
if (methodDescriptor2 != null) {
|
||
|
|
return methodDescriptor2;
|
||
|
|
}
|
||
|
|
synchronized (GMq.class) {
|
||
|
|
methodDescriptor = b;
|
||
|
|
if (methodDescriptor == null) {
|
||
|
|
methodDescriptor = MethodDescriptor.newBuilder().setType(MethodDescriptor.MethodType.BIDI_STREAMING).setFullMethodName(MethodDescriptor.generateFullMethodName("google.firestore.v1.Firestore", "Write")).setSampledToLocalTracing(true).setRequestMarshaller(ProtoLiteUtils.marshaller(mnR.e())).setResponseMarshaller(ProtoLiteUtils.marshaller(C1151WuV.b())).build();
|
||
|
|
b = methodDescriptor;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return methodDescriptor;
|
||
|
|
}
|
||
|
|
|
||
|
|
public static MethodDescriptor<C0993Tei, ZMV> a() {
|
||
|
|
MethodDescriptor<C0993Tei, ZMV> methodDescriptor;
|
||
|
|
MethodDescriptor<C0993Tei, ZMV> methodDescriptor2 = e;
|
||
|
|
if (methodDescriptor2 != null) {
|
||
|
|
return methodDescriptor2;
|
||
|
|
}
|
||
|
|
synchronized (GMq.class) {
|
||
|
|
methodDescriptor = e;
|
||
|
|
if (methodDescriptor == null) {
|
||
|
|
methodDescriptor = MethodDescriptor.newBuilder().setType(MethodDescriptor.MethodType.BIDI_STREAMING).setFullMethodName(MethodDescriptor.generateFullMethodName("google.firestore.v1.Firestore", "Listen")).setSampledToLocalTracing(true).setRequestMarshaller(ProtoLiteUtils.marshaller(C0993Tei.b())).setResponseMarshaller(ProtoLiteUtils.marshaller(ZMV.a())).build();
|
||
|
|
e = methodDescriptor;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return methodDescriptor;
|
||
|
|
}
|
||
|
|
|
||
|
|
public static RVV e(Channel channel) {
|
||
|
|
return (RVV) RVV.newStub(new AbstractStub.StubFactory<RVV>() { // from class: o.GMq.2
|
||
|
|
@Override // io.grpc.stub.AbstractStub.StubFactory
|
||
|
|
public final /* synthetic */ RVV newStub(Channel channel2, CallOptions callOptions) {
|
||
|
|
return new RVV(channel2, callOptions, (byte) 0);
|
||
|
|
}
|
||
|
|
}, channel);
|
||
|
|
}
|
||
|
|
|
||
|
|
/* loaded from: classes2.dex */
|
||
|
|
public static final class RVV extends AbstractAsyncStub<RVV> {
|
||
|
|
/* synthetic */ RVV(Channel channel, CallOptions callOptions, byte b) {
|
||
|
|
this(channel, callOptions);
|
||
|
|
}
|
||
|
|
|
||
|
|
private RVV(Channel channel, CallOptions callOptions) {
|
||
|
|
super(channel, callOptions);
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // io.grpc.stub.AbstractStub
|
||
|
|
public final /* synthetic */ AbstractStub build(Channel channel, CallOptions callOptions) {
|
||
|
|
return new RVV(channel, callOptions);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|