diff --git a/lib/units/device/plugins/screen/stream.js b/lib/units/device/plugins/screen/stream.js
index 4c72d3b9..5b4eb26b 100644
--- a/lib/units/device/plugins/screen/stream.js
+++ b/lib/units/device/plugins/screen/stream.js
@@ -28,6 +28,7 @@ module.exports = syrup.serial()
     var plugin = Object.create(null)
 
     function FrameProducer(config) {
+      EventEmitter.call(this)
       this.actionQueue = []
       this.runningState = FrameProducer.STATE_STOPPED
       this.desiredState = new StateQueue()
diff --git a/lib/util/failcounter.js b/lib/util/failcounter.js
index 4df55912..186abb1b 100644
--- a/lib/util/failcounter.js
+++ b/lib/util/failcounter.js
@@ -3,6 +3,7 @@ var util = require('util')
 var EventEmitter = require('eventemitter3').EventEmitter
 
 function FailCounter(threshold, time) {
+  EventEmitter.call(this)
   this.threshold = threshold
   this.time = time
   this.values = []
diff --git a/lib/util/riskystream.js b/lib/util/riskystream.js
index b953e922..643fa172 100644
--- a/lib/util/riskystream.js
+++ b/lib/util/riskystream.js
@@ -3,6 +3,8 @@ var util = require('util')
 var EventEmitter = require('eventemitter3').EventEmitter
 
 function RiskyStream(stream) {
+  EventEmitter.call(this)
+
   this.endListener = function() {
     this.ended = true
     this.stream.removeListener('end', this.endListener)
diff --git a/lib/util/ttlset.js b/lib/util/ttlset.js
index d6fd3917..0a34d3f5 100644
--- a/lib/util/ttlset.js
+++ b/lib/util/ttlset.js
@@ -10,6 +10,7 @@ function TtlItem(value) {
 }
 
 function TtlSet(ttl) {
+  EventEmitter.call(this)
   this.head = null
   this.tail = null
   this.mapping = Object.create(null)