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( |