Skip to content

S
StackExchange.Redis
Commit 9584d15b authored by Nick Craver's avatar Nick Craver
Browse files
Options

Streams: match parameter names on the wrapper

parent cdfed7cf
Hide whitespace changes
Inline Side-by-side
Showing with 4 additions and 4 deletions
StackExchange.Redis/StackExchange/Redis/KeyspaceIsolation/DatabaseWrapper.cs
View file @ 9584d15b
...@@ -662,9 +662,9 @@ public StreamPendingMessageInfo[] StreamPendingMessages(RedisKey key, RedisValue ...@@ -662,9 +662,9 @@ public StreamPendingMessageInfo[] StreamPendingMessages(RedisKey key, RedisValue
return Inner.StreamPendingMessages(ToInner(key), groupName, count, consumerName, minId, maxId, flags); return Inner.StreamPendingMessages(ToInner(key), groupName, count, consumerName, minId, maxId, flags);
} }
public RedisStreamEntry[] StreamRange(RedisKey key, RedisValue? minId = null, RedisValue? maxId = null, int? count = null, Order order = Order.Ascending, CommandFlags flags = CommandFlags.None) public RedisStreamEntry[] StreamRange(RedisKey key, RedisValue? minId = null, RedisValue? maxId = null, int? count = null, Order messageOrder = Order.Ascending, CommandFlags flags = CommandFlags.None)
{ {
return Inner.StreamRange(ToInner(key), minId, maxId, count, order, flags); return Inner.StreamRange(ToInner(key), minId, maxId, count, messageOrder, flags);
} }
public RedisStreamEntry[] StreamRead(RedisKey key, RedisValue afterId, int? count = null, CommandFlags flags = CommandFlags.None) public RedisStreamEntry[] StreamRead(RedisKey key, RedisValue afterId, int? count = null, CommandFlags flags = CommandFlags.None)
......
StackExchange.Redis/StackExchange/Redis/KeyspaceIsolation/WrapperBase.cs
View file @ 9584d15b
...@@ -641,9 +641,9 @@ public Task<StreamPendingMessageInfo[]> StreamPendingMessagesAsync(RedisKey key, ...@@ -641,9 +641,9 @@ public Task<StreamPendingMessageInfo[]> StreamPendingMessagesAsync(RedisKey key,
return Inner.StreamPendingMessagesAsync(ToInner(key), groupName, count, consumerName, minId, maxId, flags); return Inner.StreamPendingMessagesAsync(ToInner(key), groupName, count, consumerName, minId, maxId, flags);
} }
public Task<RedisStreamEntry[]> StreamRangeAsync(RedisKey key, RedisValue? minId = null, RedisValue? maxId = null, int? count = null, Order order = Order.Ascending, CommandFlags flags = CommandFlags.None) public Task<RedisStreamEntry[]> StreamRangeAsync(RedisKey key, RedisValue? minId = null, RedisValue? maxId = null, int? count = null, Order messageOrder = Order.Ascending, CommandFlags flags = CommandFlags.None)
{ {
return Inner.StreamRangeAsync(ToInner(key), minId, maxId, count, order, flags); return Inner.StreamRangeAsync(ToInner(key), minId, maxId, count, messageOrder, flags);
} }
public Task<RedisStreamEntry[]> StreamReadAsync(RedisKey key, RedisValue afterId, int? count = null, CommandFlags flags = CommandFlags.None) public Task<RedisStreamEntry[]> StreamReadAsync(RedisKey key, RedisValue afterId, int? count = null, CommandFlags flags = CommandFlags.None)
......
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