streamer = new HttpClient()
{
  BaseAddress = new Uri("http://" + url + "/")
};
var get = streamer.GetStreamAsync(streamer.BaseAddress + "!" + Uri.EscapeDataString(query));

ThreadPool.QueueUserWorkItem(new WaitCallback(connectionPending), 1);
function void connectionPending(object threadContext)
{
    while(waitForStream == true)
    {
        //re-request if stream is closed here

        Thread.Sleep(1); //sleep for 1ms.
    }
}