| /external/flatbuffers/tests/MyGame/Example/ |
| D | MonsterStorage_grpc.go | 153 func _MonsterStorage_Retrieve_Handler(srv interface{}, stream grpc.ServerStream) error { argument
161 grpc.ServerStream
165 grpc.ServerStream anonMember
169 return x.ServerStream.SendMsg(m)
173 func _MonsterStorage_GetMaxHitPoint_Handler(srv interface{}, stream grpc.ServerStream) error { argument
180 grpc.ServerStream
184 grpc.ServerStream anonMember
189 if err := x.ServerStream.RecvMsg(m); err != nil { return nil, err }
194 return x.ServerStream.SendMsg(m)
198 func _MonsterStorage_GetMinMaxHitPoints_Handler(srv interface{}, stream grpc.ServerStream) error { argument
[all …]
|
| /external/golang-protobuf/protoc-gen-go/testdata/grpc/ |
| D | grpc.pb.go | 346 func _Test_Downstream_Handler(srv interface{}, stream grpc.ServerStream) error { argument
356 grpc.ServerStream
360 grpc.ServerStream anonMember
364 return x.ServerStream.SendMsg(m)
367 func _Test_Upstream_Handler(srv interface{}, stream grpc.ServerStream) error { argument
374 grpc.ServerStream
378 grpc.ServerStream anonMember
382 return x.ServerStream.SendMsg(m)
387 if err := x.ServerStream.RecvMsg(m); err != nil {
393 func _Test_Bidi_Handler(srv interface{}, stream grpc.ServerStream) error { argument
[all …]
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | AbstractTransportTest.java | 66 import io.grpc.internal.ServerStream;
376 ServerStream serverStream = serverStreamCreation.stream; in openStreamPreventsTermination()
701 ServerStream serverStream = serverStreamCreation.stream; in basicStream()
839 ServerStream serverStream = serverStreamCreation.stream; in authorityPropagation()
858 ServerStream serverStream = serverStreamCreation.stream; in zeroMessageStream()
894 ServerStream serverStream = serverStreamCreation.stream; in earlyServerClose_withServerHeaders()
929 ServerStream serverStream = serverStreamCreation.stream; in earlyServerClose_noServerHeaders()
973 ServerStream serverStream = serverStreamCreation.stream; in earlyServerClose_serverFailure()
1020 ServerStream serverStream = serverStreamCreation.stream; in earlyServerClose_serverFailure_withClientCancelOnListenerClosed()
1122 ServerStream serverStream = serverStreamCreation.stream; in clientCancelFromWithinMessageRead()
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ServerImpl.java | 419 final ServerStream stream, final String methodName, final Metadata headers) { in streamCreated()
499 final ServerStream stream, Metadata headers, StatsTraceContext statsTraceCtx) { in createContext()
528 private <ReqT, RespT> ServerStreamListener startCall(ServerStream stream, String fullMethodName, in startCall()
550 ServerStream stream, in startWrappedCall()
637 private final ServerStream stream;
642 Executor cancelExecutor, ServerStream stream, Context.CancellableContext context) { in JumpToApplicationThreadServerStreamListener()
|
| D | ServerTransportListener.java | 34 void streamCreated(ServerStream stream, String method, Metadata headers); in streamCreated()
|
| D | ServerStream.java | 30 public interface ServerStream extends Stream { interface
|
| D | ServerCallImpl.java | 52 private final ServerStream stream;
67 ServerCallImpl(ServerStream stream, MethodDescriptor<ReqT, RespT> method, in ServerCallImpl()
|
| D | AbstractServerStream.java | 33 implements ServerStream, MessageFramer.Sink {
|
| /external/syzkaller/vendor/google.golang.org/grpc/ |
| D | interceptor.go | 77 type StreamServerInterceptor func(srv interface{}, ss ServerStream, info *StreamServerInfo, handler…
|
| D | stream.go | 44 type StreamHandler func(srv interface{}, stream ServerStream) error
628 type ServerStream interface { interface
777 func MethodFromServerStream(stream ServerStream) (string, bool) { argument
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyClientTransportTest.java | 58 import io.grpc.internal.ServerStream;
717 final ServerStream stream;
721 EchoServerStreamListener(ServerStream stream, String method, Metadata headers) { in EchoServerStreamListener()
762 public void streamCreated(ServerStream stream, String method, Metadata headers) { in transportCreated()
|
| D | NettyServerHandlerTest.java | 63 import io.grpc.internal.ServerStream;
146 public void streamCreated(ServerStream stream, String method, Metadata headers) { in streamCreated()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/ |
| D | InProcessTransport.java | 48 import io.grpc.internal.ServerStream;
299 private class InProcessServerStream implements ServerStream {
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | mock_test.cc | 293 TEST_F(MockTest, ServerStream) { in TEST_F() argument
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ServerCallImplTest.java | 63 @Mock private ServerStream stream;
|
| D | ServerImplTest.java | 189 private ServerStream stream;
|
| /external/grpc-grpc-java/core/ |
| D | grpc-core-1.14.0.jar | META-INF/
META-INF/MANIFEST.MF
io/
io/grpc/
io/ ... |