gistfile1.txt

 public void Request<TRequest, TResponse>(TRequest message, Action<TResponse> onResponse)
    where TRequest : ICorrelated
    where TResponse : ICorrelated
{
    var requester = CreateRequester<TRequest, TResponse>();
    requester.Request(message, response =>
    {
        onResponse(response);
        requester.Dispose();
    });
}

public Task<TResponse> RequestAsync<TRequest, TResponse>(TRequest message)
    where TRequest : ICorrelated
    where TResponse : ICorrelated
{
    var source = new TaskCompletionSource<TResponse>();

    var requester = CreateRequester<TRequest, TResponse>();
    requester.Request(message, response =>
    {
        source.SetResult(response);
        requester.Dispose();
    });

    return source.Task;
}