 
       describe 'receiving a broadcast message', ->
         beforeEach (done) ->
-          @redis.publish 'test:broadcast:heart', JSON.stringify(couldBe: 'The 80s band'), =>
-            done()
-
-        it 'should not get any', ->
-          expect(@onMessage).not.to.have.been.called
-
-      describe 'receiving a received message', ->
-        beforeEach (done) ->
-          @redis.publish 'test:received:heart', JSON.stringify(couldBe: 'lovesick?'), =>
-            done()
-
-        it 'should not get any', ->
-          expect(@onMessage).not.to.have.been.called
-
-      describe 'receiving a received message', ->
-        beforeEach (done) ->
-          @redis.publish 'test:received:heart', JSON.stringify(couldBe: 'lovesick?'), =>
-            done()
+          @redis.publish 'test:broadcast:heart', JSON.stringify(couldBe: 'The 80s band'), done
+
+        it 'should not get any', ->
+          expect(@onMessage).not.to.have.been.called
+
+      describe 'receiving a received message', ->
+        beforeEach (done) ->
+          @redis.publish 'test:received:heart', JSON.stringify(couldBe: 'lovesick?'), done
+
+        it 'should not get any', ->
+          expect(@onMessage).not.to.have.been.called
+
+      describe 'receiving a received message', ->
+        beforeEach (done) ->
+          @redis.publish 'test:received:heart', JSON.stringify(couldBe: 'lovesick?'), done
 
         it 'should not get any', ->
           expect(@onMessage).not.to.have.been.called

config = require '../../config'
{createClient} = require '../../lib/redis'
MessageIOClient = require '../../lib/messageIOClient'

        @sut.once 'message', @onMessage
        @sut.subscribe 'hubris', ['broadcast'], undefined, =>
          @sut.unsubscribe 'hubris', ['broadcast'], =>
            @redis.publish 'test:broadcast:hubris', JSON.stringify(that: 'would never happen to me!'), done

      beforeEach (done) ->
        setTimeout done, 100

      it 'should not get a message', ->
        expect(@onMessage).not.to.have.been.called
