race condition about gearman-node HOT 1 CLOSED

EventEmitter = require("events").EventEmitter

class Connection extends EventEmitter
  sendCommand: (cmd, name) =>
    if cmd is 'submit'
      setTimeout () =>
        @emit 'created', name
      , 1000
      setTimeout () =>
        console.log 'emitting fail', name
        @emit 'fail', name
      , 2000

class Client extends Connection
  constructor: () ->
    @jobs={}
    @on 'fail', (handle) ->
      console.log 'fail', handle, @jobs[handle]
      delete @jobs[handle]

  submitJob: (name, payload) ->
    @once 'created', (handle) ->
      console.log 'created', handle, name
      @jobs[handle] = name
    console.log 'submitting', name
    @sendCommand 'submit', name

# submit two jobs back to back
client = new Client()
client.submitJob 'test1', {}
client.submitJob 'test2', {}