github/Discord.Net
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fixed MessageQueue early edits

Browse Source
This commit is contained in:
RogueException
2016-02-11 15:47:31 -04:00
parent 255e012fe8
commit 3902b25b8a
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/Discord.Net/MessageQueue.cs
View File

@@ -45,6 +45,7 @@ namespace Discord.Net
{ {
_rest = rest; _rest = rest;
_logger = logger; _logger = logger;
_nextWarning = WarningStart;
_nonceRand = new Random(); _nonceRand = new Random();
_pendingSends = new ConcurrentQueue<Message>(); _pendingSends = new ConcurrentQueue<Message>();
@@ -73,7 +74,7 @@ namespace Discord.Net
internal void QueueEdit(Message msg, string text) internal void QueueEdit(Message msg, string text)
{ {
string msgText = msg.RawText; string msgText = msg.RawText;
if (msg.State == MessageState.Queued && _pendingSendsByNonce.TryUpdate(msg.Nonce, msgText, text)) if (msg.State == MessageState.Queued && _pendingSendsByNonce.TryUpdate(msg.Nonce, text, msgText))
{ {
//Successfully edited the message before it was sent. //Successfully edited the message before it was sent.
return; return;
@@ -106,7 +107,6 @@ namespace Discord.Net
} }
private Task RunSendQueue(CancellationToken cancelToken) private Task RunSendQueue(CancellationToken cancelToken)
{ {
_nextWarning = WarningStart;
return Task.Run((Func<Task>)(async () => return Task.Run((Func<Task>)(async () =>
{ {
try try
@@ -133,7 +133,6 @@ namespace Discord.Net
} }
private Task RunEditQueue(CancellationToken cancelToken) private Task RunEditQueue(CancellationToken cancelToken)
{ {
_nextWarning = WarningStart;
return Task.Run((Func<Task>)(async () => return Task.Run((Func<Task>)(async () =>
{ {
try try
@@ -156,7 +155,6 @@ namespace Discord.Net
} }
private Task RunDeleteQueue(CancellationToken cancelToken) private Task RunDeleteQueue(CancellationToken cancelToken)
{ {
_nextWarning = WarningStart;
return Task.Run((Func<Task>)(async () => return Task.Run((Func<Task>)(async () =>
{ {
try try