Integration test for Redis Pub/Sub

IntegrationTestForRedisPubSub.cs

[Fact]
public async void ShouldPublishResultMessage()
{
    var messageContract = File.ReadAllText("MessageContract.json");
    var expected = JsonSerializer.Deserialize<Result>(messageContract);
    var subscriber = _fixture.RedisPersistence.GetSubscriber();
    var tcs = new TaskCompletionSource<Result>();
    subscriber.Subscribe("channel:result", (channel, message) =>
    {
        var result = JsonSerializer.Deserialize<Result>(message);
        tcs.SetResult(result);
    });
    await _fixture.RedisPersistence.PublishResult("channel:result", expected);
    var actual = await Task.WhenAny<Result>(tcs.Task, Task.Run<Result>(async ()=>{
        await Task.Delay(3000);
        return new Result();
    }));
    Assert.Equal(expected, actual);
}