Streaming api cleanup example

stream.coffee

class Stream extends process.EventEmitter

  constructor: (@request, @response, @channels, @user) ->
    # other initializing code
  
  get: ->
    # start streaming messages in response to a get request
    # ...
    
    # Normal cleanup after stream is closed
    @response.on 'finish', @cleanup
    @response.on 'close', @cleanup
    
    # Check that we didn't miss a close event
    @aliveCheck = setInterval(@ensureRequestIsAlive, Stream.ALIVE_CHECK_INTERVAL)

  ensureRequestIsAlive: =>
    if @request.connection.destroyed
      stats.increment('disconnect-dead-socket')
      @cleanup()

  cleanup: ->
    # do required cleanup