diff --git a/src/Redis.OM.POC/Redis.OM.POC.csproj b/src/Redis.OM.POC/Redis.OM.POC.csproj index be0711b3..474b33d9 100644 --- a/src/Redis.OM.POC/Redis.OM.POC.csproj +++ b/src/Redis.OM.POC/Redis.OM.POC.csproj @@ -13,7 +13,7 @@ - + diff --git a/src/Redis.OM/Redis.OM.csproj b/src/Redis.OM/Redis.OM.csproj index 0cee403e..1c1b592f 100644 --- a/src/Redis.OM/Redis.OM.csproj +++ b/src/Redis.OM/Redis.OM.csproj @@ -26,7 +26,7 @@ - + diff --git a/src/Redis.OM/RedisReply.cs b/src/Redis.OM/RedisReply.cs index 7bb5b458..0242e26c 100644 --- a/src/Redis.OM/RedisReply.cs +++ b/src/Redis.OM/RedisReply.cs @@ -25,23 +25,23 @@ public class RedisReply : IConvertible /// the redisResult. public RedisReply(RedisResult result) { - switch (result.Type) + switch (result.Resp2Type) { case ResultType.None: break; case ResultType.SimpleString: case ResultType.BulkString: - _raw = (byte[])result; + _raw = (byte[])result!; break; case ResultType.Error: Error = true; - _raw = (byte[])result; + _raw = (byte[])result!; break; case ResultType.Integer: _internalLong = (long)result; break; - case ResultType.MultiBulk: - _values = ((RedisResult[])result).Select(x => new RedisReply(x)).ToArray(); + case ResultType.Array: + _values = ((RedisResult[])result!).Select(x => new RedisReply(x)).ToArray(); break; } } diff --git a/test/Redis.OM.Unit.Tests/CoreTests.cs b/test/Redis.OM.Unit.Tests/CoreTests.cs index c94aa0c7..5b1b464c 100644 --- a/test/Redis.OM.Unit.Tests/CoreTests.cs +++ b/test/Redis.OM.Unit.Tests/CoreTests.cs @@ -476,8 +476,8 @@ public async Task SearchTimeoutTest() await Task.WhenAll(tasks); - var ex = await Assert.ThrowsAsync(async () => await collection.Take(10000).ToListAsync()); - Assert.Equal("Encountered timeout when searching - check the duration of your query.", ex.Message); + var ex = await Assert.ThrowsAsync(async () => await collection.Take(10000).ToListAsync()); + Assert.True(ex.Message.Equals("Encountered timeout when searching - check the duration of your query.") || ex.Message.Contains("Timeout limit was reached")); } } } \ No newline at end of file