AsyncEventEmitter

asynceventemitter.coffee

class AsyncEventEmitter
  constructor : () ->
    @_dict = {}

  emit : (eventName, args...) ->
    if @_dict[eventName]?
      (process.nextTick () -> 
        callback.apply null, args) for callback in @_dict[eventName]
  
  once : (eventName, callback) ->
    if not @_dict[eventName]?
      @_dict[eventName] = []
    @_dict[eventName].push callback


exports.AsyncEventEmitter = AsyncEventEmitter

test.coffee

#!/usr/bin/env coffee
EventEmitter = require('events').EventEmitter
AsyncEventEmitter = require('./asynceventemitter').AsyncEventEmitter

#emitter = new EventEmitter()
emitter = new AsyncEventEmitter()

foo = (a) ->
  a += 1
  console.log '0.calc.a'
  emitter.emit 'calc.a', a
  console.log '1.calc.a'

bar = (b) ->
  b += 10
  console.log '0.calc.b'
  emitter.emit 'calc.b', b
  console.log '1.calc.b'


emitter.once 'calc.a', bar
emitter.once 'calc.b', (b) ->
  x = (num for num in [1..10000000])
  console.log "b=%d", b

foo 1


# 0.calc.a
# 1.calc.a
# 0.calc.b
# 1.calc.b
# b=12