anchor.diff:          | Deferred(data, errors, deferred) -> 
               empty errors
               data.["data"] |> equals (upcast expectedDirect)
  -            deferred |> Observable.add(equals (upcast expectedDeferred))
  +            deferred |> Observable.add (fun x -> actualDeferred.Add(x); mre.Set() |> ignore)
  +            if TimeSpan.FromSeconds(float 30) |> mre.WaitOne |> not
  +            then fail "Timeout while waiting for Deferred GQLResponse"
  +            actualDeferred |> single |> equals (upcast expectedDeferred)
           | _ -> fail "Expected Deferred GQLResponse")
   
   [<Fact>]
  
positive.code:            ]
         }
  
  
      let Query = 
          Define.Object<TestSubject>(
              name = "Query",
  
negative.code:             b
          }
      }"""
      use mre = new ManualResetEvent(false)
      let actualDeferred = ConcurrentBag<Output>()
      asts query
      |> Seq.map (executor.AsyncExecute >> sync)
      |> Seq.iter (fun result ->
  