using System;

using System.Threading;

using System.Threading.Tasks;

using System.Runtime.Remoting.Messaging;

​

namespace SO

{

    public class Program

    {

        static async Task WorkAsync(CancellationToken token)

        {

            await Task.Delay(1000, token);

            throw new ApplicationException("Surprise!");

        }

​

        static async Task TestAsync(int timeout)

        {

            var cts = new CancellationTokenSource(timeout);

            try

            {

                await WorkAsync(cts.Token).Convert();

            }

            catch (Exception ex)

            {

                Console.WriteLine(ex.Message);

            }

        }

​

        static async Task TestCallContextAsync()

        {

            const string key = "some_key";

            CallContext.LogicalSetData(key, "some_value");

            await Task.Delay(100).Convert();

            Console.WriteLine(key + ": " + CallContext.LogicalGetData(key));

        }

​

        public static void Main()

        {

            TestAsync(500).Wait();

            TestAsync(2000).Wait();

            TestCallContextAsync().Wait();

            Console.WriteLine("Enter to exit...");

            Console.ReadLine();

        }

    }

​

    public struct Empty

    {

        public static readonly Empty Value = default(Empty);

    }

​

    public static class TaskExt

    {

​

        public static Task<Empty> Convert(this Task @this)

        {

            return @this.ContinueWith(t =>

            {

                // propagate exceptions without wrapping

                t.GetAwaiter().GetResult();

                return Empty.Value;

            }, TaskContinuationOptions.ExecuteSynchronously);

        }

    }

}

​