Get it! Thank you for your help. You are wonderful. > Oh i think i missed the grpc proto file. But its the same as present in > git repository example folder. This code is modification of example present > in grpc source. You just need to make a small change, add "stream" keyword > in return argument. > > https://github.com/grpc/grpc/blob/master/examples/protos/route_guide.proto > > -Chaitanya > > On Wed, Aug 16, 2017 at 9:21 PM, <[email protected] <javascript:>> wrote: > >> >> <https://lh3.googleusercontent.com/-IFt0j6BXsBM/WZRn3sCljJI/AAAAAAAAACw/41WMt9RqrI4yZxZ6Wd1QJM6ga7ejLelbACEwYBhgL/s1600/files.png> >> >> >> <https://lh3.googleusercontent.com/-eGsW4yITGd0/WZRn8_oGFAI/AAAAAAAAAC0/HhbIdO7Jf7QvoU4bl-cgZ5QA1yvc2mPggCEwYBhgL/s1600/filelist.png> >> >> >> >> <https://lh3.googleusercontent.com/-KKoWxmspnx8/WZRo6sTVS2I/AAAAAAAAADA/8fLzTOnzk-cVKZ71Oi3i-XNAmUGn7t4pQCLcBGAs/s1600/filelist2.png> >> >> >> >> >> Hi Chaitanya, >> >> There are two rar files inside the share, I can't find proto directory or >> files in both of them. please help me. >> >> Thanks >> Sean >> >> >> proto file is in same folder under proto directory. >>> >>> On Wed, Aug 16, 2017 at 8:51 PM, <[email protected]> wrote: >>> >>>> Hi Chaitanya, >>>> >>>> Thank you for you sharing! Can you provide the .proto file with it? >>>> It's hard to understand without the .proto file, and I can't change the >>>> code and recompile it. >>>> >>>> Thanks >>>> Sean >>>> >>>> Hi John, >>>>> >>>>> I have added 2 variant of routeguide example, one for asyn stream with >>>>> one rpc and other for async stream multiple rpc. You can take a look at >>>>> the >>>>> code. this was working with grpc 0_11 version. This will give you a good >>>>> idea of how to use grpc for asyn stream. >>>>> >>>>> https://drive.google.com/open?id=0B1MMqYKUHgtJQWN4cjB6U25LdTQ >>>>> >>>>> Thanks >>>>> Chaitanya >>>>> >>>>> On Thu, Jun 15, 2017 at 6:39 PM, John Coffey <[email protected]> wrote: >>>>> >>>>>> Chaitanya, >>>>>> >>>>>> that would be really useful, thanks, I will look forward to seeing >>>>>> the code. It is strange that gRPC does not have asynchronous stream >>>>>> support, you would think this kind of listener/observe pattern would be >>>>>> a >>>>>> pretty popular feature. >>>>>> >>>>>> John >>>>>> >>>>>> >>>>>> On Thursday, June 15, 2017 at 12:55:10 AM UTC-4, Chaitanya Gangwar >>>>>> wrote: >>>>>>> >>>>>>> Hi John, >>>>>>> >>>>>>> When i was working on this, there was no example in grpc package to >>>>>>> do the same. Actually, what you need here is asynchronous streaming, >>>>>>> but in >>>>>>> examples, there are 2 variant, one is synchronous stream (routeguide) >>>>>>> and >>>>>>> normal async rpc (helloworld). You have to understand both the examples >>>>>>> and >>>>>>> need to implement async stream yourself. I may have some poc code with >>>>>>> me >>>>>>> where i tested this functionality. Ill check my repo and will post it >>>>>>> to >>>>>>> you. May be that will be of some help for you. >>>>>>> >>>>>>> Thanks >>>>>>> Chaitanya >>>>>>> >>>>>>> On Thu, Jun 15, 2017 at 12:38 AM, John Coffey <[email protected]> >>>>>>> wrote: >>>>>>> >>>>>>>> Josh/Chaitanya, I have a similar application - are there any C++ >>>>>>>> examples that do this kind of thing? I just posted a new question to >>>>>>>> the >>>>>>>> newsgroup asking and then I found this thread. >>>>>>>> >>>>>>>> John >>>>>>>> >>>>>>>> On Friday, January 22, 2016 at 4:53:42 PM UTC-5, Josh Humphries >>>>>>>> wrote: >>>>>>>>> >>>>>>>>> There is an example of streaming, at least in a proto file: >>>>>>>>> >>>>>>>>> https://github.com/grpc/grpc/blob/master/examples/protos/hellostreamingworld.proto >>>>>>>>> In this case, the server is expected to just immediately send the >>>>>>>>> requested number of messages. >>>>>>>>> >>>>>>>>> >>>>>>>>> Assuming you had some "registry" of streams that represent clients >>>>>>>>> to which you forward data: >>>>>>>>> >>>>>>>>> In your server implementation, you'd just register the >>>>>>>>> StreamObserver (that's what its called in the Java runtime >>>>>>>>> <https://github.com/grpc/grpc-java/blob/master/stub/src/main/java/io/grpc/stub/StreamObserver.java> >>>>>>>>> >>>>>>>>> anyway). >>>>>>>>> >>>>>>>>> Here's example generated code for an endpoint with a streaming >>>>>>>>> response: >>>>>>>>> https://github.com/grpc/grpc-java/blob/master/examples/src/generated/main/grpc/io/grpc/examples/routeguide/RouteGuideGrpc.java#L80 >>>>>>>>> (That's the interface you implement on the server.) >>>>>>>>> >>>>>>>>> When your server receives data from whatever other source, it can >>>>>>>>> consult this registry of streams and then call onNext to send the >>>>>>>>> client(s) >>>>>>>>> data. Unregister when the stream errors or when you close the stream. >>>>>>>>> You >>>>>>>>> close it via calling onComplete or onError (latter will send error >>>>>>>>> code to >>>>>>>>> the client). >>>>>>>>> >>>>>>>>> >>>>>>>>> >>>>>>>>> ---- >>>>>>>>> *Josh Humphries* >>>>>>>>> Manager, Shared Systems | Platform Engineering >>>>>>>>> Atlanta, GA | 678-400-4867 >>>>>>>>> *Square* (www.squareup.com) >>>>>>>>> >>>>>>>>> On Fri, Jan 22, 2016 at 3:51 PM, Chaitanya Gangwar < >>>>>>>>> [email protected]> wrote: >>>>>>>>> >>>>>>>>>> Thanks josh for the reply. So for this case i need both async >>>>>>>>>> server and client. sync rpc will not work. please correct me if i am >>>>>>>>>> wrong. >>>>>>>>>> also do we have any example which i can look into. i checked async >>>>>>>>>> helloworld but that is simple rpc do we have any example for async >>>>>>>>>> stream >>>>>>>>>> rpc. >>>>>>>>>> >>>>>>>>>> On Friday, 22 January 2016 12:28:18 UTC-8, Chaitanya Gangwar >>>>>>>>>> wrote: >>>>>>>>>>> >>>>>>>>>>> Hi, >>>>>>>>>>> >>>>>>>>>>> I have a requirement, where multiple clients send (register) a >>>>>>>>>>> request to server and continue, whenever server have data, server >>>>>>>>>>> will push >>>>>>>>>>> the data to clients. it may be possible that server may not have >>>>>>>>>>> data at >>>>>>>>>>> present and will keep pushing data whenever it has. Some other >>>>>>>>>>> thread is >>>>>>>>>>> providing the data to server. >>>>>>>>>>> >>>>>>>>>>> Can i do this with grpc without blocking the server and client. >>>>>>>>>>> What i understand from grpc streaming is that client will be >>>>>>>>>>> waiting for >>>>>>>>>>> data till server sends out the data and after receiving the data it >>>>>>>>>>> closes >>>>>>>>>>> the connection. >>>>>>>>>>> >>>>>>>>>>> please help, if i can do this using grpc and if yes how should i >>>>>>>>>>> design this. >>>>>>>>>>> >>>>>>>>>>> thanks >>>>>>>>>>> Chaitanya >>>>>>>>>>> >>>>>>>>>>> -- >>>>>>>>>> You received this message because you are subscribed to the >>>>>>>>>> Google Groups "grpc.io" group. >>>>>>>>>> To unsubscribe from this group and stop receiving emails from it, >>>>>>>>>> send an email to [email protected]. >>>>>>>>>> To post to this group, send email to [email protected]. >>>>>>>>>> To view this discussion on the web visit >>>>>>>>>> https://groups.google.com/d/msgid/grpc-io/586023c6-8a37-4662-a592-0047b7c916d4%40googlegroups.com >>>>>>>>>> >>>>>>>>>> <https://groups.google.com/d/msgid/grpc-io/586023c6-8a37-4662-a592-0047b7c916d4%40googlegroups.com?utm_medium=email&utm_source=footer> >>>>>>>>>> . >>>>>>>>>> >>>>>>>>>> For more options, visit https://groups.google.com/d/optout. >>>>>>>>>> >>>>>>>>> >>>>>>>>> -- >>>>>>>> You received this message because you are subscribed to a topic in >>>>>>>> the Google Groups "grpc.io" group. >>>>>>>> To unsubscribe from this topic, visit >>>>>>>> https://groups.google.com/d/topic/grpc-io/FKeg4yfB-Jo/unsubscribe. >>>>>>>> To unsubscribe from this group and all its topics, send an email to >>>>>>>> [email protected]. >>>>>>>> To post to this group, send email to [email protected]. >>>>>>>> Visit this group at https://groups.google.com/group/grpc-io. >>>>>>>> To view this discussion on the web visit >>>>>>>> https://groups.google.com/d/msgid/grpc-io/3533c9ab-ad6a-4566-9e49-ed438d565eb3%40googlegroups.com >>>>>>>> >>>>>>>> <https://groups.google.com/d/msgid/grpc-io/3533c9ab-ad6a-4566-9e49-ed438d565eb3%40googlegroups.com?utm_medium=email&utm_source=footer> >>>>>>>> . >>>>>>>> >>>>>>>> For more options, visit https://groups.google.com/d/optout. >>>>>>>> >>>>>>> >>>>>>> -- >>>>>> You received this message because you are subscribed to a topic in >>>>>> the Google Groups "grpc.io" group. >>>>>> To unsubscribe from this topic, visit >>>>>> https://groups.google.com/d/topic/grpc-io/FKeg4yfB-Jo/unsubscribe. >>>>>> To unsubscribe from this group and all its topics, send an email to >>>>>> [email protected]. >>>>>> To post to this group, send email to [email protected]. >>>>>> Visit this group at https://groups.google.com/group/grpc-io. >>>>>> To view this discussion on the web visit >>>>>> https://groups.google.com/d/msgid/grpc-io/15c847d8-5111-410b-8ddf-912bbc631135%40googlegroups.com >>>>>> >>>>>> <https://groups.google.com/d/msgid/grpc-io/15c847d8-5111-410b-8ddf-912bbc631135%40googlegroups.com?utm_medium=email&utm_source=footer> >>>>>> . >>>>>> >>>>>> For more options, visit https://groups.google.com/d/optout. >>>>>> >>>>> >>>>> -- >>>> You received this message because you are subscribed to a topic in the >>>> Google Groups "grpc.io" group. >>>> To unsubscribe from this topic, visit >>>> https://groups.google.com/d/topic/grpc-io/FKeg4yfB-Jo/unsubscribe. >>>> To unsubscribe from this group and all its topics, send an email to >>>> [email protected]. >>>> To post to this group, send email to [email protected]. >>>> Visit this group at https://groups.google.com/group/grpc-io. >>>> To view this discussion on the web visit >>>> https://groups.google.com/d/msgid/grpc-io/5a3db516-4f2b-4206-b6ad-182a5f4a7595%40googlegroups.com >>>> >>>> <https://groups.google.com/d/msgid/grpc-io/5a3db516-4f2b-4206-b6ad-182a5f4a7595%40googlegroups.com?utm_medium=email&utm_source=footer> >>>> . >>>> >>>> For more options, visit https://groups.google.com/d/optout. >>>> >>> >>> -- >> You received this message because you are subscribed to a topic in the >> Google Groups "grpc.io" group. >> To unsubscribe from this topic, visit >> https://groups.google.com/d/topic/grpc-io/FKeg4yfB-Jo/unsubscribe. >> To unsubscribe from this group and all its topics, send an email to >> [email protected] <javascript:>. >> To post to this group, send email to [email protected] >> <javascript:>. >> Visit this group at https://groups.google.com/group/grpc-io. >> To view this discussion on the web visit >> https://groups.google.com/d/msgid/grpc-io/ea09d67b-8a6b-45a1-8500-4598b064c592%40googlegroups.com >> >> <https://groups.google.com/d/msgid/grpc-io/ea09d67b-8a6b-45a1-8500-4598b064c592%40googlegroups.com?utm_medium=email&utm_source=footer> >> . >> >> For more options, visit https://groups.google.com/d/optout. >> > >
-- You received this message because you are subscribed to the Google Groups "grpc.io" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at https://groups.google.com/group/grpc-io. To view this discussion on the web visit https://groups.google.com/d/msgid/grpc-io/1558ab65-f7c9-4ea6-88ec-e8299752d48a%40googlegroups.com. For more options, visit https://groups.google.com/d/optout.
