diff --git a/stream/messaging.go b/stream/messaging.go
index 05d55ad..a53c427 100644
--- a/stream/messaging.go
+++ b/stream/messaging.go
@@ -75,3 +75,8 @@ func (s *Stream) Unregister(output chan []byte) {
 		close(output)
 	}
 }
+
+// Count number of outputs
+func (s *Stream) Count() int {
+	return len(s.outputs)
+}