using System;

using System.Linq;

using System.Collections.Concurrent;

public class Program

{

    public static void Main()

    {

        new BlockingCollectionCheck<int>().RunTestWithSingleItem(5);

        new BlockingCollectionCheck<int>().RunTestWithSingleItem(default(int));

        new BlockingCollectionCheck<object>().RunTestWithSingleItem(new object());

    }

    public class BlockingCollectionCheck<T>{

        public void RunTestWithSingleItem(T item){

            var x = new BlockingCollection<T>();

            x.Add(item);

            var ce = x.GetConsumingEnumerable();

            x.CompleteAdding();

​

            var y = ce.SingleOrDefault();

            if(!y.Equals(default(T)))

            {

                Console.WriteLine("Any was true.");

                if(y.Equals(item)){

                    Console.WriteLine("Successfully retrieved a " + item.ToString() + "!");

                }

                else{

                    Console.WriteLine("Failed: Expected " + item.ToString() + ", but received " + y.ToString());

                }

            }

            else

            {

                Console.WriteLine("Any was FALSE.");

            }

        }

    }

}