public void TestLockedMonth() {
      _em = new DomainModel.DomainModelEntityManager();
      var task1 = AsyncSerialTask.Create();
      var task2 = task1.AddAsyncLogin(_em1, new LoginCredential(null, null, null));
      var task3 = task2.AddAction(x => Assert.IsTrue(_em1.IsLoggedIn));
      var task4 = task3.AddAction(x => Assert.IsTrue(_em1.IsConnected));
      var task5 = task4.AddAsyncAction<AsyncEventArgs>((x, cb) => InitializeCacheAsync(cb, TestLockedMonthCallback));
      EnqueueCallback(() => task5.Execute(null, args => TestLockedMonthCallback2(args)));
    }
    // Take 2 args here - 1 the serial task callback, the other the parallel task completion action.
    public void InitializeCacheAsync(AsyncCompletedCallback<AsyncEventArgs> serialCB, Action<AsyncParallelTaskCompletedArgs> completionAction) {
      var task = AsyncParallelTask.Create();
      task.AddAsyncQuery(1, x => _defaultManager.AccountingMonths);
      task.AddAsyncQuery(2, x => _defaultManager.DealTypes);
      // Any object can be passed as input and available to the completion action.
      task.Execute(serialCB, completionAction);
    }
    // Parallel task completion action
    public void TestLockedMonthCallback(AsyncParallelTaskCompletedArgs args) {
      // We passed this callback as input parm into the AsyncParallelTask
      var serialCB = args.ExecutionInput as AsyncCompletedCallback<AsyncEventArgs>;
      // Build new args, taking advantage of userState input argument.
      AsyncEventArgs newArgs = null;
      if (args.Ok) {
        // This is arbitrary - here we supply parallel task completion info ...
        newArgs = new AsyncEventArgs(args.CompletionMap);
      } else {
        // Also arbitrary - if parallel task failed provide some info ...
        newArgs = new AsyncEventArgs(args.Errors[0].Exception, false, args.Errors);
      }
      // Now call the serial task's callback action.
      serialCB(newArgs);
    }
    // Called when serial task completes.
    public void TestLockedMonthCallback2(AsyncSerialTaskCompletedArgs<AsyncEventArgs> args) {
      // Result here is the result from the parallel task completion.
      var result = args.Result;
      var completionMap = result.UserState as Dictionary<object, AsyncEventArgs>;
      TestExit();
    }