           return reject err if err
           resolve eventNames
 
-      .catch (err) ->
+      findEvents.catch (err) ->
         reject err
+
 
   _subscribeProjectionToDomainEvents: (projectionId, projectionName, projection, eventNames, aggregateId, context) ->
     new Promise (resolve, reject) =>


  destroyInstance: (projectionId, context) ->
    return unless @_handlerFunctions[projectionId]
    
    for subscriberId in @_handlerFunctions[projectionId]
      context.unsubscribeFromDomainEvent subscriberId
    delete @_handlerFunctions[projectionId]

        findEvents = context.findDomainEventsByName eventNames

      findEvents.then (domainEvents) =>
        if not domainEvents or domainEvents.length is 0
          return resolve eventNames

