anchor.diff:      }"""
       use mre = new ManualResetEvent(false)
       let actualDeferred = ConcurrentBag<Output>()
  +    resetLiveData ()
       let result = query |> executor.AsyncExecute |> sync
       match result with
       | Deferred(data, errors, deferred) ->
  
positive.code:         | _ -> fail "Expected Deferred GQLResponse")
  
  [<Fact>]
  let ``Live Query`` () =
      let expectedDirect =
          NameValueLookup.ofList [
  
negative.code:         deferred
          |> Observable.add (fun x -> actualDeferred.Add(x); set mre)
          waitFor hasSubscribers 10 "Timeout while waiting for subscribers on GQLResponse"
          updateLiveData ()
          wait mre "Timeout while waiting for Deferred GQLResponse"
          actualDeferred
          |> Seq.cast<NameValueLookup>
  