EventSource Web API C#

using System;
using System.Collections.Concurrent;
using System.Threading;
using System.Web.Mvc;
using Newtonsoft.Json;

namespace EventSourceTest2.Controllers {
    public class PingData {
        public int UserID { get; set; }
        public DateTime Date { get; set; } = DateTime.Now;
    }

    public class HomeController : Controller {
        public ActionResult Index() {
            return View();
        }

        static ConcurrentQueue<PingData> pings = new ConcurrentQueue<PingData>();

        public void Ping(int userID) {
            pings.Enqueue(new PingData { UserID = userID });
        }

        public void Message() {
            Response.ContentType = "text/event-stream";
            do {
                PingData nextPing;
                if (pings.TryDequeue(out nextPing)) {
                    Response.Write("data:" + JsonConvert.SerializeObject(nextPing, Formatting.None) + "\n\n");
                }
                Response.Flush();
                Thread.Sleep(1000);
            } while (true);
        }
    }
}

Source: stackoverflow.com

Similar codes

5 votes192 views7 answers
If statement
C#
1 vote185 views1 answer
How c# connection
C#
0 vote225 views1 answer
Regular expression alphanumeric dash space c#
C#
1 vote218 views1 answer
Unity 3d camera rotate up and down
C#
1 vote296 views1 answer
C# unity change key input in inspector
C#Unity
1 vote190 views1 answer
C# KERNEL32.DLL recoverdeleted files
C#
2 votes181 views2 answers
Missingpluginexception (missingpluginexception(no implementation found for method firebase#initializecore on channel plugins.flutter.io/firebase_core)
C#
0 vote178 views6 answers
C# .net JwtSecurityTokenHandler jwttoken claims to object
C#
0 vote164 views1 answer
Unity switch to scene and transfer data
C#
-1 vote201 views1 answer
C# The request was aborted: Could not create SSL/TLS secure
C#