       testSetEqual test, _.pluck(Posts.find().fetch(), '_id'), @posts
       test.equal Counts.findOne(@countId)?.count, @posts.length
 
-      Meteor.subscribe 'posts', @posts, expect()
+      Meteor.subscribe 'posts', @posts,
+        onReady: expect()
+        onError: (error) ->
+          test.exception error
       @usersPostsSubscribe.stop()
 
       # Let's wait a but for subscription to really stop

Users = new Meteor.Collection "Users_meteor_related_tests"
Posts = new Meteor.Collection "Posts_meteor_related_tests"

intersectionObjects = (array, rest...) ->
  _.filter _.uniq(array), (item) ->

    (test, expect) ->
      testSetEqual test, _.pluck(Posts.find().fetch(), '_id'), []
      test.equal Counts.findOne(@countId)?.count, 0

      @usersPostsSubscribe.stop()
      @usersPostsCount.stop()
  ]

  testAsyncMulti 'related - unsubscribing', [
