Re: [grpc-io] Re: using grpc for push notification

2018-03-16 Thread mscudieri78 via grpc.io
Could you please repost the examples of th c++ async route guide demos, 
Would be very helpful.

Thanks, Marco.

Am Mittwoch, 16. August 2017 17:33:38 UTC+2 schrieb Chaitanya Gangwar:
>
> proto file is in same folder under proto directory.
>
> On Wed, Aug 16, 2017 at 8:51 PM,  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  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  
> 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 
>>> 
>>>  
>>> 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 <
>>> chaitany...@gmail.com> 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 

Re: [grpc-io] Re: using grpc for push notification

2017-11-29 Thread ravijo
Hi Chaitanya,

Could you please share async stream code? 
The link seem to be broken now.

thanks.

On Thursday, June 15, 2017 at 8:54:52 AM UTC-7, Chaitanya Gangwar wrote:
>
> 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  > 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  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 
> 
>  
> 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 <
> chaitany...@gmail.com> 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, 
>> 

Re: [grpc-io] Re: using grpc for push notification

2017-08-16 Thread piratf . me
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,  wrote:
>
>>
>> 
>>
>>
>> 
>>
>>
>>
>> 
>>
>>
>>
>>
>> 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,  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  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  
>>> 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 
> 
>  
> 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*

Re: [grpc-io] Re: using grpc for push notification

2017-08-16 Thread chaitanya gangwar
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,  wrote:

>
> 
>
>
> 
>
>
>
> 
>
>
>
>
> 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,  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  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 
>> 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/hel
 lostreamingworld.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
 
 anyway).

 Here's example generated code for an endpoint with a streaming
 response: https://github.com/grpc/grpc-java/blob/master/exam
 ples/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 <
 chaitany...@gmail.com> wrote:

> Thanks josh 

Re: [grpc-io] Re: using grpc for push notification

2017-08-16 Thread piratf . me












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,  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  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  
> 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 
>>> 
>>>  
>>> 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 <
>>> chaitany...@gmail.com> 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 

Re: [grpc-io] Re: using grpc for push notification

2017-08-16 Thread chaitanya gangwar
proto file is in same folder under proto directory.

On Wed, Aug 16, 2017 at 8:51 PM,  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  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  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/hel
>> lostreamingworld.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
>> 
>> anyway).
>>
>> Here's example generated code for an endpoint with a streaming
>> response: https://github.com/grpc/grpc-java/blob/master/exam
>> ples/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 <
>> chaitany...@gmail.com> 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

Re: [grpc-io] Re: using grpc for push notification

2017-08-16 Thread piratf . me
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  > 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  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 
> 
>  
> 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 <
> chaitany...@gmail.com> 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 

Re: [grpc-io] Re: using grpc for push notification

2017-08-16 Thread piratf . me
Hi Chaitanya,

Thank you for you share! 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

在 2017年6月15日星期四 UTC+8下午11:54:52,Chaitanya Gangwar写道:
>
> 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  > 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  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 
> 
>  
> 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 <
> chaitany...@gmail.com> 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 

Re: [grpc-io] Re: using grpc for push notification

2017-06-15 Thread chaitanya gangwar
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  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  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/hel
 lostreamingworld.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
 
 anyway).

 Here's example generated code for an endpoint with a streaming
 response: https://github.com/grpc/grpc-java/blob/master/exam
 ples/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 <
 chaitany...@gmail.com> 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 grpc-io+u...@googlegroups.com.
> To post to this group, send email to grp...@googlegroups.com.
> To view this discussion on the web visit
> https://groups.google.com/d/msgid/grpc-io/586023c6-8a37-4662
> -a592-0047b7c916d4%40googlegroups.com
> 

Re: [grpc-io] Re: using grpc for push notification

2017-06-15 Thread John Coffey
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  > 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 
>>> 
>>>  
>>> 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 <
>>> chaitany...@gmail.com> 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 grpc-io+u...@googlegroups.com.
 To post to this group, send email to grp...@googlegroups.com.
 To view this discussion on the web visit 
 https://groups.google.com/d/msgid/grpc-io/586023c6-8a37-4662-a592-0047b7c916d4%40googlegroups.com
  
 
 .

 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 
>> grpc-io+u...@googlegroups.com .
>> To post to this group, send email to grp...@googlegroups.com 
>> .
>> 

Re: [grpc-io] Re: using grpc for push notification

2017-06-14 Thread chaitanya gangwar
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  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/hel
>> lostreamingworld.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
>> 
>> anyway).
>>
>> Here's example generated code for an endpoint with a streaming response:
>> https://github.com/grpc/grpc-java/blob/master/exam
>> ples/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 > > 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 grpc-io+u...@googlegroups.com.
>>> To post to this group, send email to grp...@googlegroups.com.
>>> To view this discussion on the web visit https://groups.google.com/d/ms
>>> gid/grpc-io/586023c6-8a37-4662-a592-0047b7c916d4%40googlegroups.com
>>> 
>>> .
>>>
>>> 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
> grpc-io+unsubscr...@googlegroups.com.
> To post to this group, send email to grpc-io@googlegroups.com.
> 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
> 
> .
>
> 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 

Re: [grpc-io] Re: using grpc for push notification

2017-06-14 Thread John Coffey
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 
> 
>  
> 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  > 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 grpc-io+u...@googlegroups.com .
>> To post to this group, send email to grp...@googlegroups.com 
>> .
>> To view this discussion on the web visit 
>> https://groups.google.com/d/msgid/grpc-io/586023c6-8a37-4662-a592-0047b7c916d4%40googlegroups.com
>>  
>> 
>> .
>>
>> 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 grpc-io+unsubscr...@googlegroups.com.
To post to this group, send email to grpc-io@googlegroups.com.
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.
For more options, visit https://groups.google.com/d/optout.