Блог

У меня есть очень простой сервис, построенный на приложении Vapor. Служба использует данные из другого семейства служб. Очевидно, что это именно то приложение map , для которого были созданы методы.

Все обратные вызовы в цепочке выполняются, но последний EventLoopFuture в цепочке никогда не завершается, в результате чего моя служба зависает на неопределенный срок.

Этот код выполняет один асинхронный вызов, чтобы получить идентификатор сеанса, а затем использует эти данные для проверки, является ли человек членом определенной группы. Вызовы другой службы возвращают разумные значения — в настоящее время второй вызов всегда возвращает ошибку.

Когда я вызываю этот метод, все обратные вызовы выполняются и ведут себя так, как ожидалось.

Обратите внимание, что в этом фрагменте кода я «развязал» этапы последовательности, чтобы попытаться пролить свет на то, где возникает проблема, но на общее поведение это не влияет.

Я пробовал много разных перестановок цепочки, используя flatMap , map , и flatMapError , где это уместно, без изменения конечного результата.

 let authService = remoteApi.authServices();

// EventLoopFuture<String> with sessionId
let sessionIdFuture = authService.getSessionId(username: userName, password: password)

// EventLoopFuture<Bool> with whether the user is in a particular group
let gsFuture = sessionIdFuture.flatMap { sessionId -> EventLoopFuture<Bool> in
    let groupMemberService = remoteApi.groupMemberServices()
    return groupMemberService.personIsInGroup(sessionId: sessionId, groupId: groupId, userId: userId)
}

// EventLoopFuture<Bool> if the above has an error, just return false
let errorFuture = gsFuture.flatMapErrorThrowing { error in
    // This executes successfully!
    return false
}

// EventLoopFuture<String> with the return data 
let returnFuture = errorFuture.flatMapThrowing { isMember -> String in
    // This executes successfully!
    let response = PersonIsMemberResponse(isMember: isMember)
    if let json = self.encodeResponse(response) {
        print(json) // {"isMember": false}
        return json
    } else {
        throw Abort(.internalServerError, reason: "could not encode our own dang data type");
    }
}.always { result in
    // This executes!
    do {
        try remoteApi.shutdown()
    } catch {
        print(error)
    }
}

gsFuture.whenComplete { result in
    // This executes!
    print("gsFuture complete!")
}
errorFuture.whenComplete { result in
     // This executes!
   print("errorFuture complete!")
}
returnFuture.whenComplete { result in
    // This DOES NOT execute!
    print("returnFuture complete!")
}
 

Я не вижу, как последнее flatMapThrowing может быть выполнено и вернуть значение, тогда будущее не завершено. Чего мне не хватает?

Как мы вместе выяснили в комментариях, похоже try remoteApi.shutdown() , что это блокировка, которая предотвращает дальнейшее развитие событий.