Commit dcf17987 authored by Marc Gravell's avatar Marc Gravell

Add some missing ForAwait()s

parent 050053a9
...@@ -1307,7 +1307,7 @@ internal async Task<bool> ReconfigureAsync(bool first, bool reconfigureAll, Text ...@@ -1307,7 +1307,7 @@ internal async Task<bool> ReconfigureAsync(bool first, bool reconfigureAll, Text
// so we will get list of other nodes from this server using "CLUSTER NODES" command // so we will get list of other nodes from this server using "CLUSTER NODES" command
// and try to connect to these other nodes in the next iteration // and try to connect to these other nodes in the next iteration
encounteredConnectedClusterServer = true; encounteredConnectedClusterServer = true;
updatedClusterEndpointCollection = await GetEndpointsFromClusterNodes(server, log); updatedClusterEndpointCollection = await GetEndpointsFromClusterNodes(server, log).ForAwait();
} }
// set the server UnselectableFlags and update masters list // set the server UnselectableFlags and update masters list
...@@ -1465,7 +1465,7 @@ private async Task<EndPointCollection> GetEndpointsFromClusterNodes(ServerEndPoi ...@@ -1465,7 +1465,7 @@ private async Task<EndPointCollection> GetEndpointsFromClusterNodes(ServerEndPoi
var message = Message.Create(-1, CommandFlags.None, RedisCommand.CLUSTER, RedisLiterals.NODES); var message = Message.Create(-1, CommandFlags.None, RedisCommand.CLUSTER, RedisLiterals.NODES);
try try
{ {
var clusterConfig = await ExecuteAsyncImpl(message, ResultProcessor.ClusterNodes, null, server); var clusterConfig = await ExecuteAsyncImpl(message, ResultProcessor.ClusterNodes, null, server).ForAwait();
return new EndPointCollection(clusterConfig.Nodes.Select(node => node.EndPoint).ToList()); return new EndPointCollection(clusterConfig.Nodes.Select(node => node.EndPoint).ToList());
} }
catch (Exception ex) catch (Exception ex)
......
...@@ -200,7 +200,7 @@ public async Task<LoadedLuaScript> LoadAsync(IServer server, CommandFlags flags ...@@ -200,7 +200,7 @@ public async Task<LoadedLuaScript> LoadAsync(IServer server, CommandFlags flags
throw new ArgumentOutOfRangeException(nameof(flags), "Loading a script cannot be FireAndForget"); throw new ArgumentOutOfRangeException(nameof(flags), "Loading a script cannot be FireAndForget");
} }
var hash = await server.ScriptLoadAsync(ExecutableScript, flags); var hash = await server.ScriptLoadAsync(ExecutableScript, flags).ForAwait();
return new LoadedLuaScript(this, hash); return new LoadedLuaScript(this, hash);
} }
......
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