Commit efbc2dc8 authored by Nick Craver's avatar Nick Craver

Streams: fix pending message tests

Was incorrectly failing when completing near-instantly with a local server.
parent 19cad7d2
using System; using System;
using System.Linq; using System.Linq;
using System.Threading.Tasks;
using Xunit; using Xunit;
using Xunit.Abstractions; using Xunit.Abstractions;
...@@ -481,7 +482,7 @@ public void StreamConsumerGroupViewPendingInfoSummary() ...@@ -481,7 +482,7 @@ public void StreamConsumerGroupViewPendingInfoSummary()
} }
[Fact] [Fact]
public void StreamConsumerGroupViewPendingMessageInfo() public async Task StreamConsumerGroupViewPendingMessageInfo()
{ {
var key = GetUniqueKey("group_pending_messages"); var key = GetUniqueKey("group_pending_messages");
var groupName = "test_group"; var groupName = "test_group";
...@@ -507,6 +508,8 @@ public void StreamConsumerGroupViewPendingMessageInfo() ...@@ -507,6 +508,8 @@ public void StreamConsumerGroupViewPendingMessageInfo()
// Read the remaining messages into the second consumer. // Read the remaining messages into the second consumer.
var consumer2Messages = db.StreamReadGroup(key, groupName, consumer2); var consumer2Messages = db.StreamReadGroup(key, groupName, consumer2);
await Task.Delay(10);
// Get the pending info about the messages themselves. // Get the pending info about the messages themselves.
var pendingMessageInfoList = db.StreamPendingMessages(key, groupName, 10, RedisValue.Null); var pendingMessageInfoList = db.StreamPendingMessages(key, groupName, 10, RedisValue.Null);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment