using System;

using System.Text;

using System.Collections;

using System.Collections.Generic;

using System.IO;

using YamlDotNet.Serialization;

using System.IO.Pipes;

using System.Threading;

using YamlDotNet.Core;

using YamlDotNet.Core.Events;

using System.Collections.Concurrent;

​

public class Program

{

    public static void Main()

    {   

        var pipe = new BlockingCollection<char>(new ConcurrentQueue<char>());

        // Setup a writer that will write documents periodically to the pipe

        var writer = new PipeWriter(pipe);

        var counter = 0;

        Timer timer = null;

        timer = new Timer(_ =>

        {

            ++counter;

            if(counter < 10)

            {

                writer.WriteLine("---\nId: {0}\nName: MyName", counter);

                writer.Flush();

            }

            else if(counter == 10)

            {

                writer.WriteLine("...");

                writer.Flush();

                writer.Close();

            }

        }, null, 300, 300);

​

        var deserializer = new Deserializer();

        var eventReader = new EventReader(new Parser(new PipeReader(pipe)));

        // Consume the initial StreamStart

        eventReader.Expect<StreamStart>();

        // Read each document

        do

        {

            var data = deserializer.Deserialize<Datablock>(eventReader);

            Console.WriteLine("{0}\t{1}\t{2}", DateTime.Now, data.Id, data.Name);

        }

        while(!eventReader.Accept<StreamEnd>());

        timer.Dispose();

        Console.WriteLine("Done");

    }

}

​

public class Datablock

{

    public int Id { get; set; }

    public string Name { get; set; }

}

​

public class PipeReader : TextReader

{

    private readonly BlockingCollection<char> _pipe;

    public PipeReader(BlockingCollection<char> pipe)

    {

        _pipe = pipe;

    }

    public override int Read()

    {

        if(_pipe.IsCompleted)

        {

            return -1;

        }

        return _pipe.Take();

    }

}

​

public class PipeWriter : TextWriter

{

    private readonly BlockingCollection<char> _pipe;

    public PipeWriter(BlockingCollection<char> pipe)

    {

        _pipe = pipe;

    }

    public override Encoding Encoding { get { return Encoding.UTF8; } }

    public override void Write(char value)

    {

        _pipe.Add(value);

    }

    public override void Close()

    {

        _pipe.CompleteAdding();

    }

}

​