CSharpSSEClient

StreamingAPIClient.cs

namespace StreamingAPIClient
{
    public static class Program
    {

        public static async Task Main(string[] args)
        {
            Console.WriteLine("Run sample client");

            HttpClient client = new HttpClient();
            client.Timeout = TimeSpan.FromSeconds(5);

            while (true)
            {
                try
                {
                    Console.WriteLine("Establishing connection with the server ...");
                    using (var streamReader =
                           new StreamReader(await client.GetStreamAsync("http://localhost:8080/stream")))
                    {
                        while (!streamReader.EndOfStream)
                        {
                            var message = await streamReader.ReadLineAsync();
                            Console.WriteLine(message);
                        }
                    }
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message);
                }
            }

        }
    }
}