EasyNetQ BusExtensions ConnectionAwaiter

BusExtensions.cs

public static class BusExtensions
{
    public static Task ConnectionAwaiter(this IBus bus)
    {
        var cts = new TaskCompletionSource<bool>(TaskCreationOptions.RunContinuationsAsynchronously);

        bus.Advanced.Connected += (s, e) =>
        {
            cts.TrySetResult(true);
        };

        if (bus.IsConnected)
        {
            cts.TrySetResult(true);
        }

        return cts.Task;
    }
}

Program.cs

class Program
{
    static void Main(string[] args)
    {
        var app = new Application();
        app.Run().Wait();
    }
}

public class Application
{
    public async Task Run()
    {
        LogProvider.SetCurrentLogProvider(ConsoleLogProvider.Instance);

        var bus = RabbitHutch.CreateBus("host=localhost;virtualHost=ConsoleApp6");

        await bus.ConnectionAwaiter();

        bus.SubscribeAsync<MyMessage>("test", msg => Task.CompletedTask);

        Console.ReadLine();

        bus.Dispose();
    }
}

public class MyMessage { }

you can use this instead of SpinWait.SpinUntil(() => bus.IsConnected);