wasSharp
//Collections/Specialized/ObservableConcurrentQueue.cs |
@@ -25,7 +25,7 @@ |
EnqueueAsync(item).RunSynchronously(); |
} |
|
public async Task EnqueueAsync(T item) => await Task.Run(() => |
public Task EnqueueAsync(T item) => Task.Run(() => |
{ |
base.Enqueue(item); |
|
@@ -42,9 +42,9 @@ |
return true; |
} |
|
public async Task<T> DequeueAsync() => await Task.Run(() => |
public Task<T> DequeueAsync() => Task.Run(() => |
{ |
if (!base.TryDequeue(out T item)) |
if (base.IsEmpty || !base.TryDequeue(out T item)) |
return default(T); |
|
OnCollectionChanged( |