Scenario: We are receiving huge amount of voice data streams which could be upto couple of minutes long. There will huge set of data streams as an input every second. This a real time application where I get live data from multiple users and return response from api. I am using google' AsyncStreamingRecognize to create stream. This stream open, read and write functions are blocking as I cannot proceed with other operation until success is returned by get() functions. Due to this my threads responsible for dealing with stream data are getting blocked. Is there a better way to where I can write high amount of input data without my thread being blocked for previous write function ? The code/setup works fine for a single call in real time. But I doubt how to design it well that could handle huge realtime incoming traffic
LinkedIn
Twitter
