mirror of
https://github.com/openstf/stf
synced 2025-10-04 10:19:30 +02:00
Fix user actions not extending timeout.
This commit is contained in:
parent
9b304a939c
commit
ed2390592c
2 changed files with 4 additions and 2 deletions
|
@ -10,7 +10,8 @@ module.exports = syrup.serial()
|
||||||
|
|
||||||
sub.on('message', router.handler())
|
sub.on('message', router.handler())
|
||||||
|
|
||||||
router.on('message', function(channel) {
|
// Special case, we're hooking into a message that's not actually routed.
|
||||||
|
router.on({$code: 'message'}, function(channel) {
|
||||||
channels.keepalive(channel)
|
channels.keepalive(channel)
|
||||||
})
|
})
|
||||||
|
|
||||||
|
|
|
@ -3,6 +3,7 @@ var util = require('util')
|
||||||
|
|
||||||
var wire = require('./')
|
var wire = require('./')
|
||||||
var log = require('../util/logger').createLogger('wire:router')
|
var log = require('../util/logger').createLogger('wire:router')
|
||||||
|
var on = EventEmitter.prototype.on
|
||||||
|
|
||||||
function Router() {
|
function Router() {
|
||||||
if (!(this instanceof Router)) {
|
if (!(this instanceof Router)) {
|
||||||
|
@ -15,7 +16,7 @@ function Router() {
|
||||||
util.inherits(Router, EventEmitter)
|
util.inherits(Router, EventEmitter)
|
||||||
|
|
||||||
Router.prototype.on = function(message, handler) {
|
Router.prototype.on = function(message, handler) {
|
||||||
return EventEmitter.prototype.on.call(this, message.$code, handler)
|
return on.call(this, message.$code, handler)
|
||||||
}
|
}
|
||||||
|
|
||||||
Router.prototype.removeListener = function(message, handler) {
|
Router.prototype.removeListener = function(message, handler) {
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue