swift - validate() の呼び出し時に汎用 Alamofire 呼び出し関数内の Observable.create が機能しない

Question

「ジェネリック」関数を使用して、Alamofire を使用して検証済みのネットワーク リクエストを作成したいと考えています。RX をまったく使用しない場合、または validate() または anyCustomValidate() を呼び出さない場合は正常に動作しますが、以下のように Observable.create および validate() と一緒に使用すると動作しません。代わりに次のようにします。

     1.makes tokenRefresh call
     2.receives the new token
     3.calls completion(true, 0.0) (as below)

しかし、その後何も起こりません...

これが私の一般的な機能です：

func sendRequest<Response: Codable>(endpoint: URLRequestConvertible) -> Observable<Response> {
    return Observable<Response>.create { observer in
        let request = self.session.request(endpoint)
            .validate()
            .responseJSON { response in
                print(response)
                switch response.result {
                case .success:
                    do {
                        let model = try JSONDecoder().decode(Response.self, from: response.data!)
                        observer.onNext(model)
                    } catch {
                        print("generic call function error: \(error)")
                        observer.onError(RequestError.failedParsingError(ErrTypes.somethingWrong.rawValue))
                    }
                case .failure:
                observer.onError(RequestError.failedParsingError(ErrTypes.somethingWrong.rawValue))
                }
        }
        return Disposables.create {
            request.cancel()
        }
    }.observeOn(MainScheduler.instance)
}

これを使用して特定の応答を取得する方法は次のとおりです。

func getAddresses(clientId: Int) -> Observable<[AddressesResponse]> {
    return sendRequest(endpoint: CustomerEndPoint.getAddresses(userID: clientId))
}

そして、これは私が関数を呼び出す方法です:

 @objc func buttonPressed() {
    getAddresses(clientId: 1111).subscribe(onNext: { addresses in
        print(addresses)
    }).disposed(by: disposeBag)
}

これは私の Request retrier です:

extension AuthHandler: RequestRetrier {

func should(_ manager: SessionManager, retry request: Request, with error: Error, completion: @escaping RequestRetryCompletion) {
    guard let request = request as? DataRequest, request.delegate.data != nil else { fatalError() }
    guard let headerStatusCode = request.response?.statusCode else {
        completion(false, 0.0)
        return
    }
    if headerStatusCode == 401 || headerStatusCode == 403 {
        refreshToken(success: {
            completion(true, 0.0)
        }, failure: { message in
            print(message)
        })
    } else {
        if let json = String(data: request.delegate.data!, encoding: String.Encoding.utf8),
        let jsonObject = dictionaryWithJSONString(json) as? [String:Any],
        let statusMessage = jsonObject["statusMessage"] as? [String: Any],
        let status = statusMessage["status"] as? Int {
            if status == 401 || status == 403 {
                self.refreshToken(success: {
                    completion(true, 0.0)
                }, failure: { message in
                    completion(false, 0.0)
                    print(message)
                })
            }
        }
    }
}

しばらくすると、これがコンソール ログに出力されます。

2019-02-17 22:25:13.368846+0100 AlamofireValidator[76262:1527976] [BoringSSL] nw_protocol_boringssl_get_output_frames(1301) [C1.1:2][0x7fc5cf50e020] get output frames failed, state 8196