anchor.diff:              return! wait 
           }
           
  -    let processEvent (key:Guid) values = async {
  +    let processEvent key values = async {
           let rec loop () = async {
               let! attempt = tryEvent key values
               if not attempt then
  
positive.code: 
          let myEvents = (streams, streamValues) |> Seq.unfold generateStream
  
          let processValue (value:int) (docObj:obj) =
              let doc = docObj :?> MyCountingDoc
              let isEven = doc.Count % 2 = 0
              doc.Count <- doc.Count + 1
              if isEven then
  
negative.code:         documentStore.Initialize() |> ignore
          documentStore
  
  //    [<Fact>]
  //    let ``Test Bulk Write`` () : unit =
  //        let documentStore = buildDocumentStore()
  //        let projector = new BulkRavenProjector(documentStore :> Raven.Client.IDocumentStore)
  //
  //        let docKey = "MyCountingDoc/" + Guid.NewGuid().ToString()
  //
  //        let result = 
  //            seq {
  //                let doc = new MyCountingDoc()
  //                let metadata = new Raven.Json.Linq.RavenJObject()
  //                metadata.Add("Raven-Entity-Name", new RavenJValue("MyCountingDocs"))
  //                let writeRequests = Seq.singleton {
  //                    DocumentKey = docKey
  //                    Document = lazy(RavenJObject.FromObject(doc))
  //                    Metadata = lazy(metadata)
  //                    Etag = Raven.Abstractions.Data.Etag.Empty }
  //                yield (writeRequests, (fun _ -> async { () }))
  //            }
  //            |> BatchOperations.writeBatch documentStore 
  //            |> Async.RunSynchronously
  //
  //        match result with
  //        | Some _ -> (true |> should equal true)
  //        | None -> (false |> should equal true)
  
      [<Fact>]
      let ``Pump many events at Raven`` () : unit =
          let documentStore = buildDocumentStore() :> Raven.Client.IDocumentStore 
  
          let values = [1..100]
          let streams = [for i in 1 .. 1000 -> Guid.NewGuid()]
  