anchor.diff:      let loggerName = sprintf "Darkseid[AppName:%s, Stream:%s]" appName streamName
       let logger     = LogManager.GetLogger loggerName
   
  +    let errorEvent = new Event<Record * Exception>()
  +
       let cts = new CancellationTokenSource()
    
       let virman  = new VirmanVundabar(kinesis, cloudWatch, config, appName, streamName, cts)
  
positive.code:         new Producer(kinesis, cloudWatch, config, appName, streamName)
  
      static member CreateNew(kinesis, cloudWatch, appName, streamName, config) =
          new Producer(kinesis, cloudWatch, config, appName, streamName)
negative.code:                     do! Async.Sleep 100
                      do! send record (attempts + 1)
                  | Flatten exn ->
                      errorEvent.Trigger(record, exn)
                      logger.Warn(sprintf "PutRecord request attempt [%d] encountered an error, retrying..." attempts, exn)
  
                      do! send record (attempts + 1)
  