anchor.diff:  
       [<CLIEvent>] member this.OnStopped = stoppedEvent.Publish
   
  -    member this.Stop () = 
  -        stopProcessingEvent.Trigger()
  -        stoppedEvent.Publish.Wait()
  +    member this.Stop () = stopProcessingEvent.Trigger()
   
       interface IDisposable with
           member this.Dispose () = 
  
positive.code: 
      let cts = new CancellationTokenSource()
  
      let stateTableReadyEvent = new Event<string>()
  
      let kinesis    = AWSClientFactory.CreateAmazonKinesisClient(awsKey, awsSecret, region)
      let dynamoDB   = AWSClientFactory.CreateAmazonDynamoDBClient(awsKey, awsSecret, region)    
  
negative.code: 
      let refreshSub = Observable.Interval(config.CheckStreamChangesFrequency)
                          .Subscribe(fun _ -> Async.Start(refresh, cts.Token))
      let _ = workerCountChangedEvent.Publish.Subscribe(fun n -> logDebug "Worker count changed to [{0}]" [| n |])
  
      let disposeInvoked = ref 0
      let cleanup (disposing : bool) =
          // ensure that resources are only disposed of once
  