Made Context parameter nullable

Fixed unit tests

Author: BladeBreaker

DispatchQueue/IDispatchQueue.cs

@@ -8,13 +8,13 @@ namespace Dispatch
 {
  public interface IDispatchQueue
  {
- public void DispatchAsync(object context, WaitCallback work);
+ public void DispatchAsync(object? context, WaitCallback work);
  }
 
 
  public static class IDispatchQueueExtensionMethods
  {
- public static void DispatchSync(this IDispatchQueue queue, object context, WaitCallback? work)
+ public static void DispatchSync(this IDispatchQueue queue, object? context, WaitCallback? work)
  {
  TaskCompletionSource<object?> tcs = new TaskCompletionSource<object?>();
 

DispatchQueue/SerialQueue.cs

@@ -15,7 +15,7 @@ public class SerialQueue : IDispatchQueue
  private struct WorkData
  {
  public WaitCallback Work;
- public object Context;
+ public object? Context;
  }
 
  private readonly IThreadPool mThreadPool;
@@ -41,7 +41,7 @@ public SerialQueue(IThreadPool threadPool)
  /// 
  /// </summary>
  /// <param name="task"></param>
- public void DispatchAsync(object context, WaitCallback work)
+ public void DispatchAsync(object? context, WaitCallback work)
  {
  // can't allow nulls in our queue
  if (work == null)

Tests/SerialQueueTests.cs

@@ -21,7 +21,7 @@ public void AsyncRunsOnSeparateThreads()
 
  for (int i = 0; i < 10; ++i)
  {
- queue.DispatchAsync(() =>
+ queue.DispatchAsync(null, (_) =>
  {
  Assert.AreNotEqual(threadId, Thread.CurrentThread.ManagedThreadId);
  });
@@ -37,7 +37,7 @@ public void SyncRunsOnSeparateThreads()
 
  for (int i = 0; i < 10; ++i)
  {
- queue.DispatchSync(() =>
+ queue.DispatchSync(null, (_) =>
  {
  Assert.AreNotEqual(threadId, Thread.CurrentThread.ManagedThreadId);
  });
@@ -53,7 +53,7 @@ public void SyncRunsSynchronously()
 
  for (int i = 0; i < 100; ++i)
  {
- queue.DispatchSync(() =>
+ queue.DispatchSync(null, (_) =>
  {
  Assert.AreEqual(numberTest++, i);
  });
@@ -70,7 +70,7 @@ public void TasksRunOneAtATime()
 
  for (int i = 0; i < 10; ++i)
  {
- queue.DispatchAsync(() =>
+ queue.DispatchAsync(null, (_) =>
  {
  Assert.IsFalse(taskRunning);
  taskRunning = true;
@@ -82,7 +82,7 @@ public void TasksRunOneAtATime()
  });
  }
 
- queue.DispatchSync(() =>
+ queue.DispatchSync(null, (_) =>
  {
  // just to ensure that the tests don't finish prematurely.
  });
@@ -99,13 +99,13 @@ public void TasksCompletedInProperSequence()
  for (int i = 0; i < 100; ++i)
  {
  int localValue = i;
- queue.DispatchAsync(() =>
+ queue.DispatchAsync(null, (_) =>
  {
  Assert.AreEqual(numberTest++, localValue);
  });
  }
 
- queue.DispatchSync(() =>
+ queue.DispatchSync(null, (_) =>
  {
  Assert.AreEqual(numberTest, 100);
  });