erizet / eventsource4net Goto Github PK

byte[] buffer = new byte[1024 * 8];
var taskRead = stream.ReadAsync(buffer, 0, buffer.Length, cancelToken);
try
{
    taskRead.Wait(cancelToken);
}
catch (Exception ex)
{
    _logger.Trace(ex, "ConnectedState.Run");
}
if (!cancelToken.IsCancellationRequested)
{
    int bytesRead = taskRead.Result;
    if (bytesRead > 0) // stream has not reached the end yet
    {
        //Console.WriteLine("ReadCallback {0} bytesRead", bytesRead);
        string text = Encoding.UTF8.GetString(buffer, 0, bytesRead);
        text = mRemainingText + text;
        string[] lines = StringSplitter.SplitIntoLines(text, out mRemainingText);

using EventSource4Net;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using slf4net;
using slf4net.Resolvers;

namespace ConsoleApplication1
{
    class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine("start ...");

            try
            {
                
                CancellationTokenSource cts = new CancellationTokenSource();
                EventSource es = new EventSource(new Uri("http://localhost:9999/bus/api/v1/subscribe/karli"), 50000);
                es.StateChanged += new EventHandler<StateChangedEventArgs>((o, e) => { Console.WriteLine("New state: " + e.State.ToString()); });
                es.EventReceived += new EventHandler<ServerSentEventReceivedEventArgs>((o, e) => { Console.WriteLine("--------- Msg received -----------\n" + e.Message.ToString()); });
                es.Start(cts.Token);
                Console.WriteLine("EventSource started");

                var a = Console.Read();
                cts.Cancel();
            }
            catch (Exception ex)
            {
                Console.WriteLine("dasda {0}", ex);
            }
        }

        private static void OnMessage(ServerEventMessage message)
        {
            Console.WriteLine($"OnMessage {message}");
        }
       
    }
}

start ...
slf4net: The factory resolver AppConfigFactoryResolver returned null from GetFactory().  The fallback no operation logger factory will be used instead.


Application information:
    Application domain: ConsoleApplication1.vshost.exe
    Application path: C:\Users\xxx\documents\visual studio 2015\Projects\ConsoleApplication1\ConsoleApplication1\bin\Debug\
    Machine name: XXX
EventSource started
New state: CONNECTING
New state: OPEN

$ curl "http://localhost:9999/bus/api/v1/subscribe/karli" -v
*   Trying 127.0.0.1...
* Connected to localhost (127.0.0.1) port 9999 (#0)
> GET /bus/api/v1/subscribe/karli HTTP/1.1
> Host: localhost:9999
> User-Agent: curl/7.47.0
> Accept: */*
>
< HTTP/1.1 200
< Content-Type: application/stream+json
< Transfer-Encoding: chunked
< Date: Thu, 28 Jun 2018 05:00:01 GMT
<
{"key":"1","offset":3,"value":{}}