Home
last modified time | relevance | path

Searched refs:ReqT (Results 1 – 25 of 68) sorted by relevance

123

/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
DServerCalls.java49 public static <ReqT, RespT> ServerCallHandler<ReqT, RespT> asyncUnaryCall( in asyncUnaryCall()
50 UnaryMethod<ReqT, RespT> method) { in asyncUnaryCall() argument
59 public static <ReqT, RespT> ServerCallHandler<ReqT, RespT> asyncServerStreamingCall( in asyncServerStreamingCall()
60 ServerStreamingMethod<ReqT, RespT> method) { in asyncServerStreamingCall() argument
69 public static <ReqT, RespT> ServerCallHandler<ReqT, RespT> asyncClientStreamingCall( in asyncClientStreamingCall()
70 ClientStreamingMethod<ReqT, RespT> method) { in asyncClientStreamingCall() argument
79 public static <ReqT, RespT> ServerCallHandler<ReqT, RespT> asyncBidiStreamingCall( in asyncBidiStreamingCall()
80 BidiStreamingMethod<ReqT, RespT> method) { in asyncBidiStreamingCall() argument
87 public interface UnaryMethod<ReqT, RespT> extends UnaryRequestMethod<ReqT, RespT> {}
92 public interface ServerStreamingMethod<ReqT, RespT> extends UnaryRequestMethod<ReqT, RespT> {}
[all …]
DClientCalls.java61 public static <ReqT, RespT> void asyncUnaryCall( in asyncUnaryCall()
62 ClientCall<ReqT, RespT> call, ReqT req, StreamObserver<RespT> responseObserver) { in asyncUnaryCall() argument
71 public static <ReqT, RespT> void asyncServerStreamingCall( in asyncServerStreamingCall()
72 ClientCall<ReqT, RespT> call, ReqT req, StreamObserver<RespT> responseObserver) { in asyncServerStreamingCall() argument
83 public static <ReqT, RespT> StreamObserver<ReqT> asyncClientStreamingCall( in asyncClientStreamingCall()
84 ClientCall<ReqT, RespT> call, in asyncClientStreamingCall() argument
95 public static <ReqT, RespT> StreamObserver<ReqT> asyncBidiStreamingCall( in asyncBidiStreamingCall()
96 ClientCall<ReqT, RespT> call, StreamObserver<RespT> responseObserver) { in asyncBidiStreamingCall() argument
106 public static <ReqT, RespT> RespT blockingUnaryCall(ClientCall<ReqT, RespT> call, ReqT req) { in blockingUnaryCall() argument
122 public static <ReqT, RespT> RespT blockingUnaryCall( in blockingUnaryCall()
[all …]
DMetadataUtils.java72 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in interceptCall()
73 MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next) { in interceptCall() argument
74 return new HeaderAttachingClientCall<ReqT, RespT>(next.newCall(method, callOptions)); in interceptCall()
77 private final class HeaderAttachingClientCall<ReqT, RespT>
78 extends SimpleForwardingClientCall<ReqT, RespT> {
81 HeaderAttachingClientCall(ClientCall<ReqT, RespT> call) { in HeaderAttachingClientCall() argument
136 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in interceptCall()
137 MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next) { in interceptCall() argument
138 return new MetadataCapturingClientCall<ReqT, RespT>(next.newCall(method, callOptions)); in interceptCall()
141 private final class MetadataCapturingClientCall<ReqT, RespT>
[all …]
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DServerMethodDefinition.java24 public final class ServerMethodDefinition<ReqT, RespT> {
25 private final MethodDescriptor<ReqT, RespT> method;
26 private final ServerCallHandler<ReqT, RespT> handler;
28 private ServerMethodDefinition(MethodDescriptor<ReqT, RespT> method, in ServerMethodDefinition() argument
29 ServerCallHandler<ReqT, RespT> handler) { in ServerMethodDefinition() argument
41 public static <ReqT, RespT> ServerMethodDefinition<ReqT, RespT> create( in create()
42 MethodDescriptor<ReqT, RespT> method, in create() argument
43 ServerCallHandler<ReqT, RespT> handler) { in create() argument
44 return new ServerMethodDefinition<ReqT, RespT>(method, handler); in create()
48 public MethodDescriptor<ReqT, RespT> getMethodDescriptor() { in getMethodDescriptor()
[all …]
DMethodDescriptor.java40 public final class MethodDescriptor<ReqT, RespT> {
44 private final Marshaller<ReqT> requestMarshaller;
221 Marshaller<ReqT> requestMarshaller, in MethodDescriptor()
277 public InputStream streamRequest(ReqT requestMessage) { in streamRequest()
288 public ReqT parseRequest(InputStream input) { in parseRequest()
310 public Marshaller<ReqT> getRequestMarshaller() { in getRequestMarshaller()
402 public static <ReqT, RespT> Builder<ReqT, RespT> newBuilder() { in newBuilder()
412 public static <ReqT, RespT> Builder<ReqT, RespT> newBuilder( in newBuilder()
413 Marshaller<ReqT> requestMarshaller, Marshaller<RespT> responseMarshaller) { in newBuilder()
414 return new Builder<ReqT, RespT>() in newBuilder()
[all …]
DServerStreamTracer.java76 public abstract static class ServerCallInfo<ReqT, RespT> {
77 public abstract MethodDescriptor<ReqT, RespT> getMethodDescriptor(); in getMethodDescriptor()
91 private static final class ReadOnlyServerCall<ReqT, RespT>
92 extends ForwardingServerCall<ReqT, RespT> {
93 private final ServerCallInfo<ReqT, RespT> callInfo;
95 private static <ReqT, RespT> ReadOnlyServerCall<ReqT, RespT> create( in create()
96 ServerCallInfo<ReqT, RespT> callInfo) { in create() argument
97 return new ReadOnlyServerCall<ReqT, RespT>(callInfo); in create()
100 private ReadOnlyServerCall(ServerCallInfo<ReqT, RespT> callInfo) { in ReadOnlyServerCall() argument
105 public MethodDescriptor<ReqT, RespT> getMethodDescriptor() { in getMethodDescriptor()
[all …]
DForwardingServerCallListener.java23 public abstract class ForwardingServerCallListener<ReqT>
24 extends PartialForwardingServerCallListener<ReqT> {
29 protected abstract ServerCall.Listener<ReqT> delegate(); in delegate()
32 public void onMessage(ReqT message) { in onMessage()
40 public abstract static class SimpleForwardingServerCallListener<ReqT>
41 extends ForwardingServerCallListener<ReqT> {
43 private final ServerCall.Listener<ReqT> delegate;
45 protected SimpleForwardingServerCallListener(ServerCall.Listener<ReqT> delegate) { in SimpleForwardingServerCallListener()
50 protected ServerCall.Listener<ReqT> delegate() { in delegate()
DForwardingServerCall.java22 public abstract class ForwardingServerCall<ReqT, RespT>
23 extends PartialForwardingServerCall<ReqT, RespT> {
28 protected abstract ServerCall<ReqT, RespT> delegate(); in delegate()
39 public abstract static class SimpleForwardingServerCall<ReqT, RespT>
40 extends ForwardingServerCall<ReqT, RespT> {
42 private final ServerCall<ReqT, RespT> delegate;
44 protected SimpleForwardingServerCall(ServerCall<ReqT, RespT> delegate) { in SimpleForwardingServerCall() argument
49 protected ServerCall<ReqT, RespT> delegate() { in delegate()
54 public MethodDescriptor<ReqT, RespT> getMethodDescriptor() { in getMethodDescriptor()
DForwardingClientCall.java22 public abstract class ForwardingClientCall<ReqT, RespT>
23 extends PartialForwardingClientCall<ReqT, RespT> {
28 protected abstract ClientCall<ReqT, RespT> delegate(); in delegate()
36 public void sendMessage(ReqT message) { in sendMessage()
44 public abstract static class SimpleForwardingClientCall<ReqT, RespT>
45 extends ForwardingClientCall<ReqT, RespT> {
46 private final ClientCall<ReqT, RespT> delegate;
48 protected SimpleForwardingClientCall(ClientCall<ReqT, RespT> delegate) { in SimpleForwardingClientCall() argument
53 protected ClientCall<ReqT, RespT> delegate() { in delegate()
DClientInterceptors.java104 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in wrapClientInterceptor()
105 final MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next) { in wrapClientInterceptor()
110 return new PartialForwardingClientCall<ReqT, RespT>() { in wrapClientInterceptor()
129 public void sendMessage(ReqT message) { in wrapClientInterceptor()
154 public <ReqT, RespT> ClientCall<ReqT, RespT> newCall(
155 MethodDescriptor<ReqT, RespT> method, CallOptions callOptions) {
200 public abstract static class CheckedForwardingClientCall<ReqT, RespT>
201 extends io.grpc.ForwardingClientCall<ReqT, RespT> {
203 private ClientCall<ReqT, RespT> delegate;
218 protected CheckedForwardingClientCall(ClientCall<ReqT, RespT> delegate) {
[all …]
DContexts.java44 public static <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in interceptCall()
46 ServerCall<ReqT, RespT> call, in interceptCall() argument
48 ServerCallHandler<ReqT, RespT> next) { in interceptCall() argument
51 return new ContextualizedServerCallListener<ReqT>( in interceptCall()
63 private static class ContextualizedServerCallListener<ReqT> extends
64 ForwardingServerCallListener.SimpleForwardingServerCallListener<ReqT> {
67 public ContextualizedServerCallListener(ServerCall.Listener<ReqT> delegate, Context context) { in ContextualizedServerCallListener()
73 public void onMessage(ReqT message) { in onMessage()
DServerInterceptors.java200 private static <ReqT, RespT> void wrapAndAddMethod( in wrapAndAddMethod()
201 ServerServiceDefinition.Builder serviceDefBuilder, ServerMethodDefinition<ReqT, RespT> method, in wrapAndAddMethod() argument
203 ServerCallHandler<ReqT, RespT> callHandler = method.getServerCallHandler(); in wrapAndAddMethod()
210 static final class InterceptCallHandler<ReqT, RespT> implements ServerCallHandler<ReqT, RespT> {
211 public static <ReqT, RespT> InterceptCallHandler<ReqT, RespT> create( in create()
212 ServerInterceptor interceptor, ServerCallHandler<ReqT, RespT> callHandler) { in create() argument
213 return new InterceptCallHandler<ReqT, RespT>(interceptor, callHandler); in create()
217 private final ServerCallHandler<ReqT, RespT> callHandler;
220 ServerInterceptor interceptor, ServerCallHandler<ReqT, RespT> callHandler) { in InterceptCallHandler() argument
226 public ServerCall.Listener<ReqT> startCall( in startCall()
[all …]
DInternalServerInterceptors.java24 public static <ReqT, RespT> ServerCallHandler<ReqT, RespT> interceptCallHandler( in interceptCallHandler() argument
25 ServerInterceptor interceptor, ServerCallHandler<ReqT, RespT> callHandler) { in interceptCallHandler()
36 public static <ReqT, RespT> ServerCallHandler<ReqT, RespT> interceptCallHandlerCreate( in interceptCallHandlerCreate() argument
37 ServerInterceptor interceptor, ServerCallHandler<ReqT, RespT> callHandler) { in interceptCallHandlerCreate()
DServerInterceptor.java50 <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in interceptCall()
51 ServerCall<ReqT, RespT> call, in interceptCall() argument
53 ServerCallHandler<ReqT, RespT> next); in interceptCall() argument
DServerCall.java40 public abstract class ServerCall<ReqT, RespT> {
54 public abstract static class Listener<ReqT> {
61 public void onMessage(ReqT message) {} in onMessage()
218 public abstract MethodDescriptor<ReqT, RespT> getMethodDescriptor(); in getMethodDescriptor()
/external/grpc-grpc-java/core/src/test/java/io/grpc/
DClientInterceptorsTest.java116 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in callNextTwice()
117 MethodDescriptor<ReqT, RespT> method, in callNextTwice()
137 public <ReqT, RespT> ClientCall<ReqT, RespT> newCall( in ordered()
138 MethodDescriptor<ReqT, RespT> method, CallOptions callOptions) { in ordered()
140 return (ClientCall<ReqT, RespT>) call; in ordered()
150 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in ordered()
151 MethodDescriptor<ReqT, RespT> method, in ordered()
160 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in ordered()
161 MethodDescriptor<ReqT, RespT> method, in ordered()
179 public <ReqT, RespT> ClientCall<ReqT, RespT> newCall( in orderedForward()
[all …]
DServerInterceptorsTest.java168 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in callNextTwice()
169 ServerCall<ReqT, RespT> call, in callNextTwice()
171 ServerCallHandler<ReqT, RespT> next) { in callNextTwice()
199 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in ordered()
200 ServerCall<ReqT, RespT> call, in ordered()
202 ServerCallHandler<ReqT, RespT> next) { in ordered()
209 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in ordered()
210 ServerCall<ReqT, RespT> call, in ordered()
212 ServerCallHandler<ReqT, RespT> next) { in ordered()
241 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in orderedForward()
[all …]
/external/grpc-grpc-java/core/src/main/java/io/grpc/util/
DTransmitStatusRuntimeExceptionInterceptor.java57 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in interceptCall()
58 ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next) { in interceptCall() argument
59 final ServerCall<ReqT, RespT> serverCall = new SerializingServerCall<ReqT, RespT>(call); in interceptCall()
60 ServerCall.Listener<ReqT> listener = next.startCall(serverCall, headers); in interceptCall()
61 return new ForwardingServerCallListener.SimpleForwardingServerCallListener<ReqT>(listener) { in interceptCall()
63 public void onMessage(ReqT message) { in interceptCall()
121 private static class SerializingServerCall<ReqT, RespT> extends
122 ForwardingServerCall.SimpleForwardingServerCall<ReqT, RespT> {
128 SerializingServerCall(ServerCall<ReqT, RespT> delegate) {
/external/grpc-grpc-java/services/src/test/java/io/grpc/services/
DBinaryLogProviderTest.java287 private static <ReqT, RespT> ServerCall.Listener<ReqT> startServerCallHelper( in startServerCallHelper()
288 final ServerMethodDefinition<ReqT, RespT> methodDef, in startServerCallHelper() argument
290 ServerCall<ReqT, RespT> serverCall = new NoopServerCall<ReqT, RespT>() { in startServerCallHelper()
297 public MethodDescriptor<ReqT, RespT> getMethodDescriptor() { in startServerCallHelper()
306 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in interceptCall()
307 final MethodDescriptor<ReqT, RespT> method, in interceptCall() argument
312 return new SimpleForwardingClientCall<ReqT, RespT>(next.newCall(method, callOptions)) { in interceptCall()
335 public void sendMessage(ReqT message) { in interceptCall()
339 ReqT dup = method.parseRequest(input); in interceptCall()
348 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(
[all …]
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DTransportCompressionTest.java94 public <ReqT, RespT> Listener<ReqT> interceptCall(ServerCall<ReqT, RespT> call, in getServerBuilder()
95 Metadata headers, ServerCallHandler<ReqT, RespT> next) { in getServerBuilder()
96 Listener<ReqT> listener = next.startCall(call, headers); in getServerBuilder()
135 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall(
136 MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next) {
137 final ClientCall<ReqT, RespT> call = next.newCall(method, callOptions);
138 return new ForwardingClientCall<ReqT, RespT>() {
141 protected ClientCall<ReqT, RespT> delegate() {
DCompressionTest.java261 public <ReqT, RespT> io.grpc.ServerCall.Listener<ReqT> interceptCall( in interceptCall()
262 ServerCall<ReqT, RespT> call, Metadata headers, ServerCallHandler<ReqT, RespT> next) { in interceptCall() argument
276 public <ReqT, RespT> ClientCall<ReqT, RespT> interceptCall( in interceptCall()
277 MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next) { in interceptCall() argument
281 ClientCall<ReqT, RespT> call = next.newCall(method, callOptions); in interceptCall()
283 return new ClientCompressor<ReqT, RespT>(call); in interceptCall()
287 private class ClientCompressor<ReqT, RespT> extends SimpleForwardingClientCall<ReqT, RespT> {
288 protected ClientCompressor(ClientCall<ReqT, RespT> delegate) { in ClientCompressor() argument
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DServerCallImpl.java43 final class ServerCallImpl<ReqT, RespT> extends ServerCall<ReqT, RespT> {
53 private final MethodDescriptor<ReqT, RespT> method;
67 ServerCallImpl(ServerStream stream, MethodDescriptor<ReqT, RespT> method, in ServerCallImpl() argument
192 ServerStreamListener newServerStreamListener(ServerCall.Listener<ReqT> listener) { in newServerStreamListener()
193 return new ServerStreamListenerImpl<ReqT>(this, listener, context); in newServerStreamListener()
207 public MethodDescriptor<ReqT, RespT> getMethodDescriptor() { in getMethodDescriptor()
227 static final class ServerStreamListenerImpl<ReqT> implements ServerStreamListener {
228 private final ServerCallImpl<ReqT, ?> call;
229 private final ServerCall.Listener<ReqT> listener;
233 ServerCallImpl<ReqT, ?> call, ServerCall.Listener<ReqT> listener, in ServerStreamListenerImpl() argument
DServerCallInfoImpl.java28 final class ServerCallInfoImpl<ReqT, RespT> extends ServerCallInfo<ReqT, RespT> {
29 private final MethodDescriptor<ReqT, RespT> methodDescriptor;
34 MethodDescriptor<ReqT, RespT> methodDescriptor, in ServerCallInfoImpl() argument
43 public MethodDescriptor<ReqT, RespT> getMethodDescriptor() { in getMethodDescriptor()
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/header/
DHeaderServerInterceptor.java40 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall( in interceptCall()
41 ServerCall<ReqT, RespT> call, in interceptCall() argument
43 ServerCallHandler<ReqT, RespT> next) { in interceptCall() argument
45 return next.startCall(new SimpleForwardingServerCall<ReqT, RespT>(call) { in interceptCall()
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DTestServiceImpl.java511 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(
512 ServerCall<ReqT, RespT> call,
514 ServerCallHandler<ReqT, RespT> next) {
515 return next.startCall(new SimpleForwardingServerCall<ReqT, RespT>(call) {
539 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(
540 ServerCall<ReqT, RespT> call,
542 ServerCallHandler<ReqT, RespT> next) {
543 return next.startCall(new SimpleForwardingServerCall<ReqT, RespT>(call) {
566 public <ReqT, RespT> ServerCall.Listener<ReqT> interceptCall(
567 ServerCall<ReqT, RespT> call,
[all …]

123