     )
 }
 
-private func extractSubscription(_ subscriptionResult: SubscriptionResult) throws -> SubscriptionObservable {
+private func extractSubscriptionFromResult(_ subscriptionResult: SubscriptionResult) throws -> SubscriptionObservable {
     switch subscriptionResult {
     case .success(let subscription):
         return subscription

            message: "Tests are good",
            unread: true
        ))
        
        XCTAssertTrue(didResolveImportantEmail)
        XCTAssertFalse(didResolveNonImportantEmail)
    }
}

// MARK: Types

        rootValue: Void(),
        context: Void(),
        eventLoopGroup: eventLoopGroup,
        variableValues: variableValues,
        operationName: nil
    ).wait()
    return try extractSubscriptionFromResult(subscriptionOrError)
}

private func emailSchemaWithResolvers(resolve: GraphQLFieldResolve? = nil, subscribe: GraphQLFieldResolve? = nil) -> GraphQLSchema {
    return try! GraphQLSchema(
        query: EmailQueryType,
        subscription: try! GraphQLObjectType(
