| /external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/routeguide/ |
| D | RouteGuideServerTest.java | 210 RouteNote n1 = RouteNote.newBuilder().setLocation(p1).setMessage("m1").build(); in routeChat()
211 RouteNote n2 = RouteNote.newBuilder().setLocation(p2).setMessage("m2").build(); in routeChat()
212 RouteNote n3 = RouteNote.newBuilder().setLocation(p1).setMessage("m3").build(); in routeChat()
213 RouteNote n4 = RouteNote.newBuilder().setLocation(p2).setMessage("m4").build(); in routeChat()
214 RouteNote n5 = RouteNote.newBuilder().setLocation(p1).setMessage("m5").build(); in routeChat()
215 RouteNote n6 = RouteNote.newBuilder().setLocation(p1).setMessage("m6").build(); in routeChat()
219 StreamObserver<RouteNote> responseObserver = in routeChat()
220 (StreamObserver<RouteNote>) mock(StreamObserver.class); in routeChat()
223 StreamObserver<RouteNote> requestObserver = stub.routeChat(responseObserver); in routeChat()
224 verify(responseObserver, never()).onNext(any(RouteNote.class)); in routeChat()
[all …]
|
| D | RouteGuideClientTest.java | 358 RouteNote fakeResponse1 = RouteNote.newBuilder().setMessage("dummy msg1").build(); in routeChat_simpleResponse()
359 RouteNote fakeResponse2 = RouteNote.newBuilder().setMessage("dummy msg2").build(); in routeChat_simpleResponse()
362 final AtomicReference<StreamObserver<RouteNote>> responseObserverRef = in routeChat_simpleResponse()
363 new AtomicReference<StreamObserver<RouteNote>>(); in routeChat_simpleResponse()
369 public StreamObserver<RouteNote> routeChat(StreamObserver<RouteNote> responseObserver) { in routeChat_simpleResponse()
372 StreamObserver<RouteNote> requestObserver = new StreamObserver<RouteNote>() { in routeChat_simpleResponse()
374 public void onNext(RouteNote value) { in routeChat_simpleResponse()
431 final List<RouteNote> notesDelivered = new ArrayList<>(); in routeChat_echoResponse()
437 public StreamObserver<RouteNote> routeChat( in routeChat_echoResponse()
438 final StreamObserver<RouteNote> responseObserver) { in routeChat_echoResponse()
[all …]
|
| /external/grpc-grpc/examples/csharp/RouteGuide/RouteGuideServer/ |
| D | RouteGuideImpl.cs | 35 … readonly Dictionary<Point, List<RouteNote>> routeNotes = new Dictionary<Point, List<RouteNote>>();
106 …override async Task RouteChat(IAsyncStreamReader<RouteNote> requestStream, IServerStreamWriter<Rou… in RouteChat()
111 List<RouteNote> prevNotes = AddNoteForLocation(note.Location, note); in RouteChat()
122 private List<RouteNote> AddNoteForLocation(Point location, RouteNote note) in AddNoteForLocation()
126 List<RouteNote> notes; in AddNoteForLocation()
128 notes = new List<RouteNote>(); in AddNoteForLocation()
131 var preexistingNotes = new List<RouteNote>(notes); in AddNoteForLocation()
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/routeguide/ |
| D | RouteGuideServer.java | 114 private final ConcurrentMap<Point, List<RouteNote>> routeNotes =
115 new ConcurrentHashMap<Point, List<RouteNote>>();
215 public StreamObserver<RouteNote> routeChat(final StreamObserver<RouteNote> responseObserver) { in routeChat()
216 return new StreamObserver<RouteNote>() { in routeChat()
218 public void onNext(RouteNote note) { in routeChat()
219 List<RouteNote> notes = getOrCreateNotes(note.getLocation()); in routeChat()
222 for (RouteNote prevNote : notes.toArray(new RouteNote[0])) { in routeChat()
245 private List<RouteNote> getOrCreateNotes(Point location) {
246 List<RouteNote> notes = Collections.synchronizedList(new ArrayList<RouteNote>());
247 List<RouteNote> prevNotes = routeNotes.putIfAbsent(location, notes);
|
| D | RouteGuideClient.java | 202 StreamObserver<RouteNote> requestObserver = in routeChat()
203 asyncStub.routeChat(new StreamObserver<RouteNote>() { in routeChat()
205 public void onNext(RouteNote note) { in routeChat()
230 RouteNote[] requests = in routeChat()
234 for (RouteNote request : requests) { in routeChat()
294 private RouteNote newNote(String message, int lat, int lon) { in newNote()
295 return RouteNote.newBuilder().setMessage(message) in newNote()
|
| /external/grpc-grpc/examples/csharp/RouteGuide/RouteGuide/ |
| D | RouteGuideGrpc.cs | 37 …RouteNote> __Marshaller_routeguide_RouteNote = grpc::Marshallers.Create((arg) => global::Google.Pr…
60 …teguide.RouteNote, global::Routeguide.RouteNote> __Method_RouteChat = new grpc::Method<global::Rou…
133 …syncStreamReader<global::Routeguide.RouteNote> requestStream, grpc::IServerStreamWriter<global::Ro… in RouteChat()
295 …irtual grpc::AsyncDuplexStreamingCall<global::Routeguide.RouteNote, global::Routeguide.RouteNote> … in RouteChat()
307 …irtual grpc::AsyncDuplexStreamingCall<global::Routeguide.RouteNote, global::Routeguide.RouteNote> … in RouteChat()
|
| D | RouteGuide.cs | 49 …new pbr::GeneratedClrTypeInfo(typeof(global::Routeguide.RouteNote), global::Routeguide.RouteNote.P… in RouteGuideReflection()
576 public sealed partial class RouteNote : pb::IMessage<RouteNote> { class
577 …ivate static readonly pb::MessageParser<RouteNote> _parser = new pb::MessageParser<RouteNote>(() =…
580 public static pb::MessageParser<RouteNote> Parser { get { return _parser; } }
593 public RouteNote() { in RouteNote() method in Routeguide.RouteNote
600 public RouteNote(RouteNote other) : this() { in RouteNote() method in Routeguide.RouteNote
607 public RouteNote Clone() { in Clone()
608 return new RouteNote(this); in Clone()
641 return Equals(other as RouteNote); in Equals()
645 public bool Equals(RouteNote other) { in Equals()
[all …]
|
| /external/grpc-grpc/examples/node/static_codegen/route_guide/ |
| D | route_guide_pb.js | 610 proto.routeguide.RouteNote = function(opt_data) { class in proto.routeguide
613 goog.inherits(proto.routeguide.RouteNote, jspb.Message);
615 proto.routeguide.RouteNote.displayName = 'proto.routeguide.RouteNote';
630 proto.routeguide.RouteNote.prototype.toObject = function(opt_includeInstance) {
631 return proto.routeguide.RouteNote.toObject(opt_includeInstance, this);
643 proto.routeguide.RouteNote.toObject = function(includeInstance, msg) {
662 proto.routeguide.RouteNote.deserializeBinary = function(bytes) {
664 var msg = new proto.routeguide.RouteNote;
665 return proto.routeguide.RouteNote.deserializeBinaryFromReader(msg, reader);
676 proto.routeguide.RouteNote.deserializeBinaryFromReader = function(msg, reader) {
[all …]
|
| D | route_guide_grpc_pb.js | 56 if (!(arg instanceof route_guide_pb.RouteNote)) {
63 return route_guide_pb.RouteNote.deserializeBinary(new Uint8Array(buffer_arg));
137 requestType: route_guide_pb.RouteNote,
138 responseType: route_guide_pb.RouteNote,
|
| /external/grpc-grpc/examples/ruby/route_guide/ |
| D | route_guide_client.rb | 110 RouteNote.new(message: 'doh - a deer',
112 RouteNote.new(message: 'ray - a drop of golden sun',
114 RouteNote.new(message: 'me - the name I call myself',
116 RouteNote.new(message: 'fa - a longer way to run',
118 RouteNote.new(message: 'soh - with needle and a thread',
|
| /external/grpc-grpc/examples/cpp/route_guide/ |
| D | route_guide_client.cc | 44 using routeguide::RouteNote;
62 RouteNote MakeRouteNote(const std::string& message, in MakeRouteNote()
64 RouteNote n; in MakeRouteNote()
157 std::shared_ptr<ClientReaderWriter<RouteNote, RouteNote> > stream( in RouteChat()
161 std::vector<RouteNote> notes{ in RouteChat()
166 for (const RouteNote& note : notes) { in RouteChat()
175 RouteNote server_note; in RouteChat()
|
| D | route_guide_server.cc | 45 using routeguide::RouteNote;
149 ServerReaderWriter<RouteNote, RouteNote>* stream) override { in RouteChat() argument
150 std::vector<RouteNote> received_notes; in RouteChat()
151 RouteNote note; in RouteChat()
153 for (const RouteNote& n : received_notes) { in RouteChat()
|
| /external/grpc-grpc/examples/python/route_guide/ |
| D | route_guide_pb2_grpc.py | 34 request_serializer=route__guide__pb2.RouteNote.SerializeToString,
35 response_deserializer=route__guide__pb2.RouteNote.FromString,
107 request_deserializer=route__guide__pb2.RouteNote.FromString,
108 response_serializer=route__guide__pb2.RouteNote.SerializeToString,
|
| D | route_guide_pb2.py | 263 RouteNote = _reflection.GeneratedProtocolMessageType('RouteNote', (_message.Message,), dict( variable
268 _sym_db.RegisterMessage(RouteNote)
|
| D | route_guide_client.py | 28 return route_guide_pb2.RouteNote(
|
| /external/grpc-grpc/examples/python/multiplex/ |
| D | route_guide_pb2_grpc.py | 34 request_serializer=route__guide__pb2.RouteNote.SerializeToString,
35 response_deserializer=route__guide__pb2.RouteNote.FromString,
107 request_deserializer=route__guide__pb2.RouteNote.FromString,
108 response_serializer=route__guide__pb2.RouteNote.SerializeToString,
|
| D | route_guide_pb2.py | 263 RouteNote = _reflection.GeneratedProtocolMessageType('RouteNote', (_message.Message,), dict( variable
268 _sym_db.RegisterMessage(RouteNote)
|
| /external/grpc-grpc/examples/csharp/RouteGuide/RouteGuideClient/ |
| D | Program.cs | 156 var requests = new List<RouteNote> in RouteChat()
176 foreach (RouteNote request in requests) in RouteChat()
206 private RouteNote NewNote(string message, int lat, int lon) in NewNote()
208 return new RouteNote in NewNote()
|
| /external/grpc-grpc/examples/ruby/lib/ |
| D | route_guide_services_pb.rb | 56 rpc :RouteChat, stream(RouteNote), stream(RouteNote)
|
| D | route_guide_pb.rb | 35 …RouteNote = Google::Protobuf::DescriptorPool.generated_pool.lookup("routeguide.RouteNote").msgclass constant
|
| /external/grpc-grpc-java/examples/android/routeguide/app/src/main/java/io/grpc/routeguideexample/ |
| D | RouteGuideActivity.java | 369 StreamObserver<RouteNote> requestObserver = in routeChat()
371 new StreamObserver<RouteNote>() { in routeChat()
373 public void onNext(RouteNote note) { in routeChat()
396 RouteNote[] requests = { in routeChat()
403 for (RouteNote request : requests) { in routeChat()
443 private static RouteNote newNote(String message, int lat, int lon) { in newNote()
444 return RouteNote.newBuilder() in newNote()
|
| /external/grpc-grpc/examples/protos/ |
| D | route_guide.proto | 52 rpc RouteChat(stream RouteNote) returns (stream RouteNote) {}
85 // A RouteNote is a message sent while at a given point.
86 message RouteNote { message
|
| /external/grpc-grpc-java/examples/android/routeguide/app/src/main/proto/ |
| D | route_guide.proto | 51 rpc RouteChat(stream RouteNote) returns (stream RouteNote) {}
89 // A RouteNote is a message sent while at a given point.
90 message RouteNote { message
|
| /external/grpc-grpc-java/examples/src/main/proto/ |
| D | route_guide.proto | 51 rpc RouteChat(stream RouteNote) returns (stream RouteNote) {}
89 // A RouteNote is a message sent while at a given point.
90 message RouteNote { message
|
| /external/grpc-grpc/examples/cpp/ |
| D | cpptutorial.md | 106 rpc RouteChat(stream RouteNote) returns (stream RouteNote) {}
267 ServerReaderWriter<RouteNote, RouteNote>* stream) override {
268 std::vector<RouteNote> received_notes;
269 RouteNote note;
271 for (const RouteNote& n : received_notes) {
465 std::shared_ptr<ClientReaderWriter<RouteNote, RouteNote> > stream(
|