| 1 | Messenger = require "../concrete/messenger"
|
| 2 |
|
| 3 | module.exports = class extends Messenger
|
| 4 |
|
| 5 |
|
| 6 | ###
|
| 7 | ###
|
| 8 |
|
| 9 | _next: (middleware) ->
|
| 10 |
|
| 11 |
|
| 12 |
|
| 13 | middleware.listener.call this, @message.query, @
|
| 14 |
|
| 15 | ## streamed data? don't dump
|
| 16 | ##if middleware.tags.stream
|
| 17 | ## middleware.listener.call this, @message, @
|
| 18 | ##else
|
| 19 |
|
| 20 | ##not streamed? load the data, then dump
|
| 21 | ## @message.dump (err, result) =>
|
| 22 |
|
| 23 | ## try
|
| 24 | ## middleware.listener.call this, result, @
|
| 25 | ## catch e
|
| 26 | ## console.error e.stack
|
| 27 | ## @response.error e
|
| 28 |
|
| 29 | ###
|
| 30 | ack on end
|
| 31 | ###
|
| 32 |
|
| 33 | _onEnd:() -> @response.end()
|