   
   set: (args..., value) ->
     key = args.join consts.arg_sep
-    @_kv.set key, value
+    @_kv.del key, =>
+      @_kv.set key, value, =>
+        @fiber.run()
+    yield()
 
   # Look up and de-jsonify a value from redis
   get: (args..., callback) ->

    clearTimeout @timeout
    @_kv.end()
    @_pubsub.end()
  
  # Send a request to the correct `requests` channel
  request: (args...) ->

        @dispatcher = dispatcher.run @opts
        @dispatcher.connect =>
          @queue.run => @expect.apply this
          setTimeout (=> (@fiber = Fiber => @setup.apply this).run()), 100
          @timeout = setTimeout (=> @die()), 5000

  # Forcefully quit the test
