|
@@ -59,7 +59,6 @@ namespace Discord.API |
|
|
private readonly AsyncEvent<Func<Exception, Task>> _disconnectedEvent = new AsyncEvent<Func<Exception, Task>>(); |
|
|
private readonly AsyncEvent<Func<Exception, Task>> _disconnectedEvent = new AsyncEvent<Func<Exception, Task>>(); |
|
|
|
|
|
|
|
|
private readonly ConcurrentDictionary<Guid, RpcRequest> _requests; |
|
|
private readonly ConcurrentDictionary<Guid, RpcRequest> _requests; |
|
|
private readonly RequestQueue _requestQueue; |
|
|
|
|
|
private readonly IWebSocketClient _webSocketClient; |
|
|
private readonly IWebSocketClient _webSocketClient; |
|
|
private readonly SemaphoreSlim _connectionLock; |
|
|
private readonly SemaphoreSlim _connectionLock; |
|
|
private readonly string _clientId; |
|
|
private readonly string _clientId; |
|
@@ -227,7 +226,7 @@ namespace Discord.API |
|
|
var requestTracker = new RpcRequest<TResponse>(options); |
|
|
var requestTracker = new RpcRequest<TResponse>(options); |
|
|
_requests[guid] = requestTracker; |
|
|
_requests[guid] = requestTracker; |
|
|
|
|
|
|
|
|
await _requestQueue.SendAsync(new WebSocketRequest(_webSocketClient, null, bytes, true, options)).ConfigureAwait(false); |
|
|
|
|
|
|
|
|
await RequestQueue.SendAsync(new WebSocketRequest(_webSocketClient, null, bytes, true, options)).ConfigureAwait(false); |
|
|
await _sentRpcMessageEvent.InvokeAsync(cmd).ConfigureAwait(false); |
|
|
await _sentRpcMessageEvent.InvokeAsync(cmd).ConfigureAwait(false); |
|
|
return await requestTracker.Promise.Task.ConfigureAwait(false); |
|
|
return await requestTracker.Promise.Task.ConfigureAwait(false); |
|
|
} |
|
|
} |
|
|