Shows how to stream events matching a filter in Seq 3.4+ back out through the console via Serilog

Install-Dependencies.ps1

Install-Package Seq.Api -Pre
Install-Package Serilog.Formatting.Compact.Reader -Pre
Install-Package Serilog.Sinks.Literate
Install-Package System.Reactive

Program.cs

using Newtonsoft.Json.Linq;
using Seq.Api;
using Serilog;
using Serilog.Formatting.Compact.Reader;
using System;
using System.Linq;
using System.Reactive.Linq;
using System.Threading.Tasks;

namespace SeqStreamingExample
{
    class Program
    {
        static void Main(string[] args)
        {
            Log.Logger = new LoggerConfiguration()
                .MinimumLevel.Verbose()
                .WriteTo.LiterateConsole()
                .CreateLogger();

            Task.Run(Run).Wait();
        }

        static async Task Run()
        {
            var connection = new SeqConnection("http://localhost:5341");

            var filter = "@Level = 'Error'";

            using (var stream = await connection.Events.StreamAsync<JObject>(filter: filter))
            using (stream.Select(jObject => LogEventReader.ReadFromJObject(jObject))
                         .Subscribe(evt => Log.Write(evt)))
            {
                await stream;
            }
        }
    }
}