Just a simple example to show how plugins ("apps") consume data from the stream

SampleReactor.cs

using Seq.Apps;
using Seq.Apps.LogEvents;

namespace Seq.BuiltIn.SampleApp
{
    public class SampleReactor : Reactor, ISubscribeTo<LogEventData>
    {
        public void On(Event<LogEventData> evt)
        {
            if (evt.Data.Level == LogEventLevel.Error)
                Log.Error("Here was an error: {RenderedMessage}", evt.Data.RenderedMessage);
        }
    }
}