@@ -48,7 +48,7 @@ namespace Discord.API
using (var reader = new StreamReader(decompressed))
using (var reader = new StreamReader(decompressed))
using (var jsonReader = new JsonTextReader(reader))
using (var jsonReader = new JsonTextReader(reader))
{
{
var msg = _serializer.Deserialize<WebSocketMessag e>(jsonReader);
var msg = _serializer.Deserialize<SocketFram e>(jsonReader);
await _receivedGatewayEvent.InvokeAsync((GatewayOpCode)msg.Operation, msg.Sequence, msg.Type, msg.Payload).ConfigureAwait(false);
await _receivedGatewayEvent.InvokeAsync((GatewayOpCode)msg.Operation, msg.Sequence, msg.Type, msg.Payload).ConfigureAwait(false);
}
}
}
}
@@ -58,7 +58,7 @@ namespace Discord.API
using (var reader = new StringReader(text))
using (var reader = new StringReader(text))
using (var jsonReader = new JsonTextReader(reader))
using (var jsonReader = new JsonTextReader(reader))
{
{
var msg = _serializer.Deserialize<WebSocketMessag e>(jsonReader);
var msg = _serializer.Deserialize<SocketFram e>(jsonReader);
await _receivedGatewayEvent.InvokeAsync((GatewayOpCode)msg.Operation, msg.Sequence, msg.Type, msg.Payload).ConfigureAwait(false);
await _receivedGatewayEvent.InvokeAsync((GatewayOpCode)msg.Operation, msg.Sequence, msg.Type, msg.Payload).ConfigureAwait(false);
}
}
};
};
@@ -164,7 +164,7 @@ namespace Discord.API
//TODO: Add ETF
//TODO: Add ETF
byte[] bytes = null;
byte[] bytes = null;
payload = new WebSocketMessag e { Operation = (int)opCode, Payload = payload };
payload = new SocketFram e { Operation = (int)opCode, Payload = payload };
if (payload != null)
if (payload != null)
bytes = Encoding.UTF8.GetBytes(SerializeJson(payload));
bytes = Encoding.UTF8.GetBytes(SerializeJson(payload));
await RequestQueue.SendAsync(new WebSocketRequest(_gatewayClient, bytes, true, options)).ConfigureAwait(false);
await RequestQueue.SendAsync(new WebSocketRequest(_gatewayClient, bytes, true, options)).ConfigureAwait(false);