[streaming api integration] Multithreading added to handle Streaming Api responses using callbacks