|
@@ -1,844 +0,0 @@
|
|
|
-//
|
|
|
|
|
-// EventMonitor.swift
|
|
|
|
|
-//
|
|
|
|
|
-// Copyright (c) 2014-2018 Alamofire Software Foundation (http://alamofire.org/)
|
|
|
|
|
-//
|
|
|
|
|
-// Permission is hereby granted, free of charge, to any person obtaining a copy
|
|
|
|
|
-// of this software and associated documentation files (the "Software"), to deal
|
|
|
|
|
-// in the Software without restriction, including without limitation the rights
|
|
|
|
|
-// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
|
|
|
|
-// copies of the Software, and to permit persons to whom the Software is
|
|
|
|
|
-// furnished to do so, subject to the following conditions:
|
|
|
|
|
-//
|
|
|
|
|
-// The above copyright notice and this permission notice shall be included in
|
|
|
|
|
-// all copies or substantial portions of the Software.
|
|
|
|
|
-//
|
|
|
|
|
-// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
|
|
|
-// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
|
|
|
-// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
|
|
|
|
-// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
|
|
|
-// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
|
|
|
|
-// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
|
|
|
|
|
-// THE SOFTWARE.
|
|
|
|
|
-//
|
|
|
|
|
-
|
|
|
|
|
-import Foundation
|
|
|
|
|
-
|
|
|
|
|
-/// Protocol outlining the lifetime events inside Alamofire. It includes both events received from the various
|
|
|
|
|
-/// `URLSession` delegate protocols as well as various events from the lifetime of `Request` and its subclasses.
|
|
|
|
|
-public protocol EventMonitor {
|
|
|
|
|
- /// The `DispatchQueue` onto which Alamofire's root `CompositeEventMonitor` will dispatch events. `.main` by default.
|
|
|
|
|
- var queue: DispatchQueue { get }
|
|
|
|
|
-
|
|
|
|
|
- // MARK: - URLSession Events
|
|
|
|
|
-
|
|
|
|
|
- // MARK: URLSessionDelegate Events
|
|
|
|
|
-
|
|
|
|
|
- /// Event called during `URLSessionDelegate`'s `urlSession(_:didBecomeInvalidWithError:)` method.
|
|
|
|
|
- func urlSession(_ session: URLSession, didBecomeInvalidWithError error: Error?)
|
|
|
|
|
-
|
|
|
|
|
- // MARK: URLSessionTaskDelegate Events
|
|
|
|
|
-
|
|
|
|
|
- /// Event called during `URLSessionTaskDelegate`'s `urlSession(_:task:didReceive:completionHandler:)` method.
|
|
|
|
|
- func urlSession(_ session: URLSession, task: URLSessionTask, didReceive challenge: URLAuthenticationChallenge)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called during `URLSessionTaskDelegate`'s `urlSession(_:task:didSendBodyData:totalBytesSent:totalBytesExpectedToSend:)` method.
|
|
|
|
|
- func urlSession(_ session: URLSession,
|
|
|
|
|
- task: URLSessionTask,
|
|
|
|
|
- didSendBodyData bytesSent: Int64,
|
|
|
|
|
- totalBytesSent: Int64,
|
|
|
|
|
- totalBytesExpectedToSend: Int64)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called during `URLSessionTaskDelegate`'s `urlSession(_:task:needNewBodyStream:)` method.
|
|
|
|
|
- func urlSession(_ session: URLSession, taskNeedsNewBodyStream task: URLSessionTask)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called during `URLSessionTaskDelegate`'s `urlSession(_:task:willPerformHTTPRedirection:newRequest:completionHandler:)` method.
|
|
|
|
|
- func urlSession(_ session: URLSession,
|
|
|
|
|
- task: URLSessionTask,
|
|
|
|
|
- willPerformHTTPRedirection response: HTTPURLResponse,
|
|
|
|
|
- newRequest request: URLRequest)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called during `URLSessionTaskDelegate`'s `urlSession(_:task:didFinishCollecting:)` method.
|
|
|
|
|
- func urlSession(_ session: URLSession, task: URLSessionTask, didFinishCollecting metrics: URLSessionTaskMetrics)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called during `URLSessionTaskDelegate`'s `urlSession(_:task:didCompleteWithError:)` method.
|
|
|
|
|
- func urlSession(_ session: URLSession, task: URLSessionTask, didCompleteWithError error: Error?)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called during `URLSessionTaskDelegate`'s `urlSession(_:taskIsWaitingForConnectivity:)` method.
|
|
|
|
|
- @available(macOS 10.13, iOS 11.0, tvOS 11.0, watchOS 4.0, *)
|
|
|
|
|
- func urlSession(_ session: URLSession, taskIsWaitingForConnectivity task: URLSessionTask)
|
|
|
|
|
-
|
|
|
|
|
- // MARK: URLSessionDataDelegate Events
|
|
|
|
|
-
|
|
|
|
|
- /// Event called during `URLSessionDataDelegate`'s `urlSession(_:dataTask:didReceive:)` method.
|
|
|
|
|
- func urlSession(_ session: URLSession, dataTask: URLSessionDataTask, didReceive data: Data)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called during `URLSessionDataDelegate`'s `urlSession(_:dataTask:willCacheResponse:completionHandler:)` method.
|
|
|
|
|
- func urlSession(_ session: URLSession, dataTask: URLSessionDataTask, willCacheResponse proposedResponse: CachedURLResponse)
|
|
|
|
|
-
|
|
|
|
|
- // MARK: URLSessionDownloadDelegate Events
|
|
|
|
|
-
|
|
|
|
|
- /// Event called during `URLSessionDownloadDelegate`'s `urlSession(_:downloadTask:didResumeAtOffset:expectedTotalBytes:)` method.
|
|
|
|
|
- func urlSession(_ session: URLSession,
|
|
|
|
|
- downloadTask: URLSessionDownloadTask,
|
|
|
|
|
- didResumeAtOffset fileOffset: Int64,
|
|
|
|
|
- expectedTotalBytes: Int64)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called during `URLSessionDownloadDelegate`'s `urlSession(_:downloadTask:didWriteData:totalBytesWritten:totalBytesExpectedToWrite:)` method.
|
|
|
|
|
- func urlSession(_ session: URLSession,
|
|
|
|
|
- downloadTask: URLSessionDownloadTask,
|
|
|
|
|
- didWriteData bytesWritten: Int64,
|
|
|
|
|
- totalBytesWritten: Int64,
|
|
|
|
|
- totalBytesExpectedToWrite: Int64)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called during `URLSessionDownloadDelegate`'s `urlSession(_:downloadTask:didFinishDownloadingTo:)` method.
|
|
|
|
|
- func urlSession(_ session: URLSession, downloadTask: URLSessionDownloadTask, didFinishDownloadingTo location: URL)
|
|
|
|
|
-
|
|
|
|
|
- // MARK: - Request Events
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when a `URLRequest` is first created for a `Request`. If a `RequestAdapter` is active, the
|
|
|
|
|
- /// `URLRequest` will be adapted before being issued.
|
|
|
|
|
- func request(_ request: Request, didCreateInitialURLRequest urlRequest: URLRequest)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when the attempt to create a `URLRequest` from a `Request`'s original `URLRequestConvertible` value fails.
|
|
|
|
|
- func request(_ request: Request, didFailToCreateURLRequestWithError error: AFError)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when a `RequestAdapter` adapts the `Request`'s initial `URLRequest`.
|
|
|
|
|
- func request(_ request: Request, didAdaptInitialRequest initialRequest: URLRequest, to adaptedRequest: URLRequest)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when a `RequestAdapter` fails to adapt the `Request`'s initial `URLRequest`.
|
|
|
|
|
- func request(_ request: Request, didFailToAdaptURLRequest initialRequest: URLRequest, withError error: AFError)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when a final `URLRequest` is created for a `Request`.
|
|
|
|
|
- func request(_ request: Request, didCreateURLRequest urlRequest: URLRequest)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when a `URLSessionTask` subclass instance is created for a `Request`.
|
|
|
|
|
- func request(_ request: Request, didCreateTask task: URLSessionTask)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when a `Request` receives a `URLSessionTaskMetrics` value.
|
|
|
|
|
- func request(_ request: Request, didGatherMetrics metrics: URLSessionTaskMetrics)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when a `Request` fails due to an error created by Alamofire. e.g. When certificate pinning fails.
|
|
|
|
|
- func request(_ request: Request, didFailTask task: URLSessionTask, earlyWithError error: AFError)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when a `Request`'s task completes, possibly with an error. A `Request` may receive this event
|
|
|
|
|
- /// multiple times if it is retried.
|
|
|
|
|
- func request(_ request: Request, didCompleteTask task: URLSessionTask, with error: AFError?)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when a `Request` is about to be retried.
|
|
|
|
|
- func requestIsRetrying(_ request: Request)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when a `Request` finishes and response serializers are being called.
|
|
|
|
|
- func requestDidFinish(_ request: Request)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when a `Request` receives a `resume` call.
|
|
|
|
|
- func requestDidResume(_ request: Request)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when a `Request`'s associated `URLSessionTask` is resumed.
|
|
|
|
|
- func request(_ request: Request, didResumeTask task: URLSessionTask)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when a `Request` receives a `suspend` call.
|
|
|
|
|
- func requestDidSuspend(_ request: Request)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when a `Request`'s associated `URLSessionTask` is suspended.
|
|
|
|
|
- func request(_ request: Request, didSuspendTask task: URLSessionTask)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when a `Request` receives a `cancel` call.
|
|
|
|
|
- func requestDidCancel(_ request: Request)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when a `Request`'s associated `URLSessionTask` is cancelled.
|
|
|
|
|
- func request(_ request: Request, didCancelTask task: URLSessionTask)
|
|
|
|
|
-
|
|
|
|
|
- // MARK: DataRequest Events
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when a `DataRequest` calls a `Validation`.
|
|
|
|
|
- func request(_ request: DataRequest,
|
|
|
|
|
- didValidateRequest urlRequest: URLRequest?,
|
|
|
|
|
- response: HTTPURLResponse,
|
|
|
|
|
- data: Data?,
|
|
|
|
|
- withResult result: Request.ValidationResult)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when a `DataRequest` creates a `DataResponse<Data?>` value without calling a `ResponseSerializer`.
|
|
|
|
|
- func request(_ request: DataRequest, didParseResponse response: DataResponse<Data?, AFError>)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when a `DataRequest` calls a `ResponseSerializer` and creates a generic `DataResponse<Value, AFError>`.
|
|
|
|
|
- func request<Value>(_ request: DataRequest, didParseResponse response: DataResponse<Value, AFError>)
|
|
|
|
|
-
|
|
|
|
|
- // MARK: UploadRequest Events
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when an `UploadRequest` creates its `Uploadable` value, indicating the type of upload it represents.
|
|
|
|
|
- func request(_ request: UploadRequest, didCreateUploadable uploadable: UploadRequest.Uploadable)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when an `UploadRequest` failed to create its `Uploadable` value due to an error.
|
|
|
|
|
- func request(_ request: UploadRequest, didFailToCreateUploadableWithError error: AFError)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when an `UploadRequest` provides the `InputStream` from its `Uploadable` value. This only occurs if
|
|
|
|
|
- /// the `InputStream` does not wrap a `Data` value or file `URL`.
|
|
|
|
|
- func request(_ request: UploadRequest, didProvideInputStream stream: InputStream)
|
|
|
|
|
-
|
|
|
|
|
- // MARK: DownloadRequest Events
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when a `DownloadRequest`'s `URLSessionDownloadTask` finishes and the temporary file has been moved.
|
|
|
|
|
- func request(_ request: DownloadRequest, didFinishDownloadingUsing task: URLSessionTask, with result: Result<URL, AFError>)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when a `DownloadRequest`'s `Destination` closure is called and creates the destination URL the
|
|
|
|
|
- /// downloaded file will be moved to.
|
|
|
|
|
- func request(_ request: DownloadRequest, didCreateDestinationURL url: URL)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when a `DownloadRequest` calls a `Validation`.
|
|
|
|
|
- func request(_ request: DownloadRequest,
|
|
|
|
|
- didValidateRequest urlRequest: URLRequest?,
|
|
|
|
|
- response: HTTPURLResponse,
|
|
|
|
|
- fileURL: URL?,
|
|
|
|
|
- withResult result: Request.ValidationResult)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when a `DownloadRequest` creates a `DownloadResponse<URL?, AFError>` without calling a `ResponseSerializer`.
|
|
|
|
|
- func request(_ request: DownloadRequest, didParseResponse response: DownloadResponse<URL?, AFError>)
|
|
|
|
|
-
|
|
|
|
|
- /// Event called when a `DownloadRequest` calls a `DownloadResponseSerializer` and creates a generic `DownloadResponse<Value, AFError>`
|
|
|
|
|
- func request<Value>(_ request: DownloadRequest, didParseResponse response: DownloadResponse<Value, AFError>)
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-extension EventMonitor {
|
|
|
|
|
- /// The default queue on which `CompositeEventMonitor`s will call the `EventMonitor` methods. `.main` by default.
|
|
|
|
|
- public var queue: DispatchQueue { return .main }
|
|
|
|
|
-
|
|
|
|
|
- // MARK: Default Implementations
|
|
|
|
|
-
|
|
|
|
|
- public func urlSession(_ session: URLSession, didBecomeInvalidWithError error: Error?) {}
|
|
|
|
|
- public func urlSession(_ session: URLSession,
|
|
|
|
|
- task: URLSessionTask,
|
|
|
|
|
- didReceive challenge: URLAuthenticationChallenge) {}
|
|
|
|
|
- public func urlSession(_ session: URLSession,
|
|
|
|
|
- task: URLSessionTask,
|
|
|
|
|
- didSendBodyData bytesSent: Int64,
|
|
|
|
|
- totalBytesSent: Int64,
|
|
|
|
|
- totalBytesExpectedToSend: Int64) {}
|
|
|
|
|
- public func urlSession(_ session: URLSession, taskNeedsNewBodyStream task: URLSessionTask) {}
|
|
|
|
|
- public func urlSession(_ session: URLSession,
|
|
|
|
|
- task: URLSessionTask,
|
|
|
|
|
- willPerformHTTPRedirection response: HTTPURLResponse,
|
|
|
|
|
- newRequest request: URLRequest) {}
|
|
|
|
|
- public func urlSession(_ session: URLSession,
|
|
|
|
|
- task: URLSessionTask,
|
|
|
|
|
- didFinishCollecting metrics: URLSessionTaskMetrics) {}
|
|
|
|
|
- public func urlSession(_ session: URLSession, task: URLSessionTask, didCompleteWithError error: Error?) {}
|
|
|
|
|
- public func urlSession(_ session: URLSession, taskIsWaitingForConnectivity task: URLSessionTask) {}
|
|
|
|
|
- public func urlSession(_ session: URLSession, dataTask: URLSessionDataTask, didReceive data: Data) {}
|
|
|
|
|
- public func urlSession(_ session: URLSession,
|
|
|
|
|
- dataTask: URLSessionDataTask,
|
|
|
|
|
- willCacheResponse proposedResponse: CachedURLResponse) {}
|
|
|
|
|
- public func urlSession(_ session: URLSession,
|
|
|
|
|
- downloadTask: URLSessionDownloadTask,
|
|
|
|
|
- didResumeAtOffset fileOffset: Int64,
|
|
|
|
|
- expectedTotalBytes: Int64) {}
|
|
|
|
|
- public func urlSession(_ session: URLSession,
|
|
|
|
|
- downloadTask: URLSessionDownloadTask,
|
|
|
|
|
- didWriteData bytesWritten: Int64,
|
|
|
|
|
- totalBytesWritten: Int64,
|
|
|
|
|
- totalBytesExpectedToWrite: Int64) {}
|
|
|
|
|
- public func urlSession(_ session: URLSession,
|
|
|
|
|
- downloadTask: URLSessionDownloadTask,
|
|
|
|
|
- didFinishDownloadingTo location: URL) {}
|
|
|
|
|
- public func request(_ request: Request, didCreateInitialURLRequest urlRequest: URLRequest) {}
|
|
|
|
|
- public func request(_ request: Request, didFailToCreateURLRequestWithError error: AFError) {}
|
|
|
|
|
- public func request(_ request: Request,
|
|
|
|
|
- didAdaptInitialRequest initialRequest: URLRequest,
|
|
|
|
|
- to adaptedRequest: URLRequest) {}
|
|
|
|
|
- public func request(_ request: Request,
|
|
|
|
|
- didFailToAdaptURLRequest initialRequest: URLRequest,
|
|
|
|
|
- withError error: AFError) {}
|
|
|
|
|
- public func request(_ request: Request, didCreateURLRequest urlRequest: URLRequest) {}
|
|
|
|
|
- public func request(_ request: Request, didCreateTask task: URLSessionTask) {}
|
|
|
|
|
- public func request(_ request: Request, didGatherMetrics metrics: URLSessionTaskMetrics) {}
|
|
|
|
|
- public func request(_ request: Request, didFailTask task: URLSessionTask, earlyWithError error: AFError) {}
|
|
|
|
|
- public func request(_ request: Request, didCompleteTask task: URLSessionTask, with error: AFError?) {}
|
|
|
|
|
- public func requestIsRetrying(_ request: Request) {}
|
|
|
|
|
- public func requestDidFinish(_ request: Request) {}
|
|
|
|
|
- public func requestDidResume(_ request: Request) {}
|
|
|
|
|
- public func request(_ request: Request, didResumeTask task: URLSessionTask) {}
|
|
|
|
|
- public func requestDidSuspend(_ request: Request) {}
|
|
|
|
|
- public func request(_ request: Request, didSuspendTask task: URLSessionTask) {}
|
|
|
|
|
- public func requestDidCancel(_ request: Request) {}
|
|
|
|
|
- public func request(_ request: Request, didCancelTask task: URLSessionTask) {}
|
|
|
|
|
- public func request(_ request: DataRequest,
|
|
|
|
|
- didValidateRequest urlRequest: URLRequest?,
|
|
|
|
|
- response: HTTPURLResponse,
|
|
|
|
|
- data: Data?,
|
|
|
|
|
- withResult result: Request.ValidationResult) {}
|
|
|
|
|
- public func request(_ request: DataRequest, didParseResponse response: DataResponse<Data?, AFError>) {}
|
|
|
|
|
- public func request<Value>(_ request: DataRequest, didParseResponse response: DataResponse<Value, AFError>) {}
|
|
|
|
|
- public func request(_ request: UploadRequest, didCreateUploadable uploadable: UploadRequest.Uploadable) {}
|
|
|
|
|
- public func request(_ request: UploadRequest, didFailToCreateUploadableWithError error: AFError) {}
|
|
|
|
|
- public func request(_ request: UploadRequest, didProvideInputStream stream: InputStream) {}
|
|
|
|
|
- public func request(_ request: DownloadRequest, didFinishDownloadingUsing task: URLSessionTask, with result: Result<URL, AFError>) {}
|
|
|
|
|
- public func request(_ request: DownloadRequest, didCreateDestinationURL url: URL) {}
|
|
|
|
|
- public func request(_ request: DownloadRequest,
|
|
|
|
|
- didValidateRequest urlRequest: URLRequest?,
|
|
|
|
|
- response: HTTPURLResponse,
|
|
|
|
|
- fileURL: URL?,
|
|
|
|
|
- withResult result: Request.ValidationResult) {}
|
|
|
|
|
- public func request(_ request: DownloadRequest, didParseResponse response: DownloadResponse<URL?, AFError>) {}
|
|
|
|
|
- public func request<Value>(_ request: DownloadRequest, didParseResponse response: DownloadResponse<Value, AFError>) {}
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-/// An `EventMonitor` which can contain multiple `EventMonitor`s and calls their methods on their queues.
|
|
|
|
|
-public final class CompositeEventMonitor: EventMonitor {
|
|
|
|
|
- public let queue = DispatchQueue(label: "org.alamofire.compositeEventMonitor", qos: .background)
|
|
|
|
|
-
|
|
|
|
|
- let monitors: [EventMonitor]
|
|
|
|
|
-
|
|
|
|
|
- init(monitors: [EventMonitor]) {
|
|
|
|
|
- self.monitors = monitors
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- func performEvent(_ event: @escaping (EventMonitor) -> Void) {
|
|
|
|
|
- queue.async {
|
|
|
|
|
- for monitor in self.monitors {
|
|
|
|
|
- monitor.queue.async { event(monitor) }
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func urlSession(_ session: URLSession, didBecomeInvalidWithError error: Error?) {
|
|
|
|
|
- performEvent { $0.urlSession(session, didBecomeInvalidWithError: error) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func urlSession(_ session: URLSession,
|
|
|
|
|
- task: URLSessionTask,
|
|
|
|
|
- didReceive challenge: URLAuthenticationChallenge) {
|
|
|
|
|
- performEvent { $0.urlSession(session, task: task, didReceive: challenge) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func urlSession(_ session: URLSession,
|
|
|
|
|
- task: URLSessionTask,
|
|
|
|
|
- didSendBodyData bytesSent: Int64,
|
|
|
|
|
- totalBytesSent: Int64,
|
|
|
|
|
- totalBytesExpectedToSend: Int64) {
|
|
|
|
|
- performEvent {
|
|
|
|
|
- $0.urlSession(session,
|
|
|
|
|
- task: task,
|
|
|
|
|
- didSendBodyData: bytesSent,
|
|
|
|
|
- totalBytesSent: totalBytesSent,
|
|
|
|
|
- totalBytesExpectedToSend: totalBytesExpectedToSend)
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func urlSession(_ session: URLSession, taskNeedsNewBodyStream task: URLSessionTask) {
|
|
|
|
|
- performEvent {
|
|
|
|
|
- $0.urlSession(session, taskNeedsNewBodyStream: task)
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func urlSession(_ session: URLSession,
|
|
|
|
|
- task: URLSessionTask,
|
|
|
|
|
- willPerformHTTPRedirection response: HTTPURLResponse,
|
|
|
|
|
- newRequest request: URLRequest) {
|
|
|
|
|
- performEvent {
|
|
|
|
|
- $0.urlSession(session,
|
|
|
|
|
- task: task,
|
|
|
|
|
- willPerformHTTPRedirection: response,
|
|
|
|
|
- newRequest: request)
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func urlSession(_ session: URLSession, task: URLSessionTask, didFinishCollecting metrics: URLSessionTaskMetrics) {
|
|
|
|
|
- performEvent { $0.urlSession(session, task: task, didFinishCollecting: metrics) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func urlSession(_ session: URLSession, task: URLSessionTask, didCompleteWithError error: Error?) {
|
|
|
|
|
- performEvent { $0.urlSession(session, task: task, didCompleteWithError: error) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- @available(macOS 10.13, iOS 11.0, tvOS 11.0, watchOS 4.0, *)
|
|
|
|
|
- public func urlSession(_ session: URLSession, taskIsWaitingForConnectivity task: URLSessionTask) {
|
|
|
|
|
- performEvent { $0.urlSession(session, taskIsWaitingForConnectivity: task) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func urlSession(_ session: URLSession, dataTask: URLSessionDataTask, didReceive data: Data) {
|
|
|
|
|
- performEvent { $0.urlSession(session, dataTask: dataTask, didReceive: data) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func urlSession(_ session: URLSession,
|
|
|
|
|
- dataTask: URLSessionDataTask,
|
|
|
|
|
- willCacheResponse proposedResponse: CachedURLResponse) {
|
|
|
|
|
- performEvent { $0.urlSession(session, dataTask: dataTask, willCacheResponse: proposedResponse) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func urlSession(_ session: URLSession,
|
|
|
|
|
- downloadTask: URLSessionDownloadTask,
|
|
|
|
|
- didResumeAtOffset fileOffset: Int64,
|
|
|
|
|
- expectedTotalBytes: Int64) {
|
|
|
|
|
- performEvent {
|
|
|
|
|
- $0.urlSession(session,
|
|
|
|
|
- downloadTask: downloadTask,
|
|
|
|
|
- didResumeAtOffset: fileOffset,
|
|
|
|
|
- expectedTotalBytes: expectedTotalBytes)
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func urlSession(_ session: URLSession,
|
|
|
|
|
- downloadTask: URLSessionDownloadTask,
|
|
|
|
|
- didWriteData bytesWritten: Int64,
|
|
|
|
|
- totalBytesWritten: Int64,
|
|
|
|
|
- totalBytesExpectedToWrite: Int64) {
|
|
|
|
|
- performEvent {
|
|
|
|
|
- $0.urlSession(session,
|
|
|
|
|
- downloadTask: downloadTask,
|
|
|
|
|
- didWriteData: bytesWritten,
|
|
|
|
|
- totalBytesWritten: totalBytesWritten,
|
|
|
|
|
- totalBytesExpectedToWrite: totalBytesExpectedToWrite)
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func urlSession(_ session: URLSession,
|
|
|
|
|
- downloadTask: URLSessionDownloadTask,
|
|
|
|
|
- didFinishDownloadingTo location: URL) {
|
|
|
|
|
- performEvent { $0.urlSession(session, downloadTask: downloadTask, didFinishDownloadingTo: location) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request(_ request: Request, didCreateInitialURLRequest urlRequest: URLRequest) {
|
|
|
|
|
- performEvent { $0.request(request, didCreateInitialURLRequest: urlRequest) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request(_ request: Request, didFailToCreateURLRequestWithError error: AFError) {
|
|
|
|
|
- performEvent { $0.request(request, didFailToCreateURLRequestWithError: error) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request(_ request: Request, didAdaptInitialRequest initialRequest: URLRequest, to adaptedRequest: URLRequest) {
|
|
|
|
|
- performEvent { $0.request(request, didAdaptInitialRequest: initialRequest, to: adaptedRequest) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request(_ request: Request, didFailToAdaptURLRequest initialRequest: URLRequest, withError error: AFError) {
|
|
|
|
|
- performEvent { $0.request(request, didFailToAdaptURLRequest: initialRequest, withError: error) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request(_ request: Request, didCreateURLRequest urlRequest: URLRequest) {
|
|
|
|
|
- performEvent { $0.request(request, didCreateURLRequest: urlRequest) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request(_ request: Request, didCreateTask task: URLSessionTask) {
|
|
|
|
|
- performEvent { $0.request(request, didCreateTask: task) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request(_ request: Request, didGatherMetrics metrics: URLSessionTaskMetrics) {
|
|
|
|
|
- performEvent { $0.request(request, didGatherMetrics: metrics) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request(_ request: Request, didFailTask task: URLSessionTask, earlyWithError error: AFError) {
|
|
|
|
|
- performEvent { $0.request(request, didFailTask: task, earlyWithError: error) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request(_ request: Request, didCompleteTask task: URLSessionTask, with error: AFError?) {
|
|
|
|
|
- performEvent { $0.request(request, didCompleteTask: task, with: error) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func requestIsRetrying(_ request: Request) {
|
|
|
|
|
- performEvent { $0.requestIsRetrying(request) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func requestDidFinish(_ request: Request) {
|
|
|
|
|
- performEvent { $0.requestDidFinish(request) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func requestDidResume(_ request: Request) {
|
|
|
|
|
- performEvent { $0.requestDidResume(request) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request(_ request: Request, didResumeTask task: URLSessionTask) {
|
|
|
|
|
- performEvent { $0.request(request, didResumeTask: task) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func requestDidSuspend(_ request: Request) {
|
|
|
|
|
- performEvent { $0.requestDidSuspend(request) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request(_ request: Request, didSuspendTask task: URLSessionTask) {
|
|
|
|
|
- performEvent { $0.request(request, didSuspendTask: task) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func requestDidCancel(_ request: Request) {
|
|
|
|
|
- performEvent { $0.requestDidCancel(request) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request(_ request: Request, didCancelTask task: URLSessionTask) {
|
|
|
|
|
- performEvent { $0.request(request, didCancelTask: task) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request(_ request: DataRequest,
|
|
|
|
|
- didValidateRequest urlRequest: URLRequest?,
|
|
|
|
|
- response: HTTPURLResponse,
|
|
|
|
|
- data: Data?,
|
|
|
|
|
- withResult result: Request.ValidationResult) {
|
|
|
|
|
- performEvent { $0.request(request,
|
|
|
|
|
- didValidateRequest: urlRequest,
|
|
|
|
|
- response: response,
|
|
|
|
|
- data: data,
|
|
|
|
|
- withResult: result)
|
|
|
|
|
- }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request(_ request: DataRequest, didParseResponse response: DataResponse<Data?, AFError>) {
|
|
|
|
|
- performEvent { $0.request(request, didParseResponse: response) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request<Value>(_ request: DataRequest, didParseResponse response: DataResponse<Value, AFError>) {
|
|
|
|
|
- performEvent { $0.request(request, didParseResponse: response) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request(_ request: UploadRequest, didCreateUploadable uploadable: UploadRequest.Uploadable) {
|
|
|
|
|
- performEvent { $0.request(request, didCreateUploadable: uploadable) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request(_ request: UploadRequest, didFailToCreateUploadableWithError error: AFError) {
|
|
|
|
|
- performEvent { $0.request(request, didFailToCreateUploadableWithError: error) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request(_ request: UploadRequest, didProvideInputStream stream: InputStream) {
|
|
|
|
|
- performEvent { $0.request(request, didProvideInputStream: stream) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request(_ request: DownloadRequest, didFinishDownloadingUsing task: URLSessionTask, with result: Result<URL, AFError>) {
|
|
|
|
|
- performEvent { $0.request(request, didFinishDownloadingUsing: task, with: result) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request(_ request: DownloadRequest, didCreateDestinationURL url: URL) {
|
|
|
|
|
- performEvent { $0.request(request, didCreateDestinationURL: url) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request(_ request: DownloadRequest,
|
|
|
|
|
- didValidateRequest urlRequest: URLRequest?,
|
|
|
|
|
- response: HTTPURLResponse,
|
|
|
|
|
- fileURL: URL?,
|
|
|
|
|
- withResult result: Request.ValidationResult) {
|
|
|
|
|
- performEvent { $0.request(request,
|
|
|
|
|
- didValidateRequest: urlRequest,
|
|
|
|
|
- response: response,
|
|
|
|
|
- fileURL: fileURL,
|
|
|
|
|
- withResult: result) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request(_ request: DownloadRequest, didParseResponse response: DownloadResponse<URL?, AFError>) {
|
|
|
|
|
- performEvent { $0.request(request, didParseResponse: response) }
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request<Value>(_ request: DownloadRequest, didParseResponse response: DownloadResponse<Value, AFError>) {
|
|
|
|
|
- performEvent { $0.request(request, didParseResponse: response) }
|
|
|
|
|
- }
|
|
|
|
|
-}
|
|
|
|
|
-
|
|
|
|
|
-/// `EventMonitor` that allows optional closures to be set to receive events.
|
|
|
|
|
-open class ClosureEventMonitor: EventMonitor {
|
|
|
|
|
- /// Closure called on the `urlSession(_:didBecomeInvalidWithError:)` event.
|
|
|
|
|
- open var sessionDidBecomeInvalidWithError: ((URLSession, Error?) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `urlSession(_:task:didReceive:completionHandler:)`.
|
|
|
|
|
- open var taskDidReceiveChallenge: ((URLSession, URLSessionTask, URLAuthenticationChallenge) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure that receives `urlSession(_:task:didSendBodyData:totalBytesSent:totalBytesExpectedToSend:)` event.
|
|
|
|
|
- open var taskDidSendBodyData: ((URLSession, URLSessionTask, Int64, Int64, Int64) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `urlSession(_:task:needNewBodyStream:)` event.
|
|
|
|
|
- open var taskNeedNewBodyStream: ((URLSession, URLSessionTask) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `urlSession(_:task:willPerformHTTPRedirection:newRequest:completionHandler:)` event.
|
|
|
|
|
- open var taskWillPerformHTTPRedirection: ((URLSession, URLSessionTask, HTTPURLResponse, URLRequest) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `urlSession(_:task:didFinishCollecting:)` event.
|
|
|
|
|
- open var taskDidFinishCollectingMetrics: ((URLSession, URLSessionTask, URLSessionTaskMetrics) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `urlSession(_:task:didCompleteWithError:)` event.
|
|
|
|
|
- open var taskDidComplete: ((URLSession, URLSessionTask, Error?) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `urlSession(_:taskIsWaitingForConnectivity:)` event.
|
|
|
|
|
- open var taskIsWaitingForConnectivity: ((URLSession, URLSessionTask) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure that receives the `urlSession(_:dataTask:didReceive:)` event.
|
|
|
|
|
- open var dataTaskDidReceiveData: ((URLSession, URLSessionDataTask, Data) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `urlSession(_:dataTask:willCacheResponse:completionHandler:)` event.
|
|
|
|
|
- open var dataTaskWillCacheResponse: ((URLSession, URLSessionDataTask, CachedURLResponse) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `urlSession(_:downloadTask:didFinishDownloadingTo:)` event.
|
|
|
|
|
- open var downloadTaskDidFinishDownloadingToURL: ((URLSession, URLSessionDownloadTask, URL) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `urlSession(_:downloadTask:didWriteData:totalBytesWritten:totalBytesExpectedToWrite:)`
|
|
|
|
|
- /// event.
|
|
|
|
|
- open var downloadTaskDidWriteData: ((URLSession, URLSessionDownloadTask, Int64, Int64, Int64) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `urlSession(_:downloadTask:didResumeAtOffset:expectedTotalBytes:)` event.
|
|
|
|
|
- open var downloadTaskDidResumeAtOffset: ((URLSession, URLSessionDownloadTask, Int64, Int64) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- // MARK: - Request Events
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `request(_:didCreateInitialURLRequest:)` event.
|
|
|
|
|
- open var requestDidCreateInitialURLRequest: ((Request, URLRequest) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `request(_:didFailToCreateURLRequestWithError:)` event.
|
|
|
|
|
- open var requestDidFailToCreateURLRequestWithError: ((Request, AFError) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `request(_:didAdaptInitialRequest:to:)` event.
|
|
|
|
|
- open var requestDidAdaptInitialRequestToAdaptedRequest: ((Request, URLRequest, URLRequest) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `request(_:didFailToAdaptURLRequest:withError:)` event.
|
|
|
|
|
- open var requestDidFailToAdaptURLRequestWithError: ((Request, URLRequest, AFError) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `request(_:didCreateURLRequest:)` event.
|
|
|
|
|
- open var requestDidCreateURLRequest: ((Request, URLRequest) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `request(_:didCreateTask:)` event.
|
|
|
|
|
- open var requestDidCreateTask: ((Request, URLSessionTask) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `request(_:didGatherMetrics:)` event.
|
|
|
|
|
- open var requestDidGatherMetrics: ((Request, URLSessionTaskMetrics) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `request(_:didFailTask:earlyWithError:)` event.
|
|
|
|
|
- open var requestDidFailTaskEarlyWithError: ((Request, URLSessionTask, AFError) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `request(_:didCompleteTask:with:)` event.
|
|
|
|
|
- open var requestDidCompleteTaskWithError: ((Request, URLSessionTask, AFError?) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `requestIsRetrying(_:)` event.
|
|
|
|
|
- open var requestIsRetrying: ((Request) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `requestDidFinish(_:)` event.
|
|
|
|
|
- open var requestDidFinish: ((Request) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `requestDidResume(_:)` event.
|
|
|
|
|
- open var requestDidResume: ((Request) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `request(_:didResumeTask:)` event.
|
|
|
|
|
- open var requestDidResumeTask: ((Request, URLSessionTask) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `requestDidSuspend(_:)` event.
|
|
|
|
|
- open var requestDidSuspend: ((Request) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `request(_:didSuspendTask:)` event.
|
|
|
|
|
- open var requestDidSuspendTask: ((Request, URLSessionTask) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `requestDidCancel(_:)` event.
|
|
|
|
|
- open var requestDidCancel: ((Request) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `request(_:didCancelTask:)` event.
|
|
|
|
|
- open var requestDidCancelTask: ((Request, URLSessionTask) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `request(_:didValidateRequest:response:data:withResult:)` event.
|
|
|
|
|
- open var requestDidValidateRequestResponseDataWithResult: ((DataRequest, URLRequest?, HTTPURLResponse, Data?, Request.ValidationResult) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `request(_:didParseResponse:)` event.
|
|
|
|
|
- open var requestDidParseResponse: ((DataRequest, DataResponse<Data?, AFError>) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `request(_:didCreateUploadable:)` event.
|
|
|
|
|
- open var requestDidCreateUploadable: ((UploadRequest, UploadRequest.Uploadable) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `request(_:didFailToCreateUploadableWithError:)` event.
|
|
|
|
|
- open var requestDidFailToCreateUploadableWithError: ((UploadRequest, AFError) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `request(_:didProvideInputStream:)` event.
|
|
|
|
|
- open var requestDidProvideInputStream: ((UploadRequest, InputStream) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `request(_:didFinishDownloadingUsing:with:)` event.
|
|
|
|
|
- open var requestDidFinishDownloadingUsingTaskWithResult: ((DownloadRequest, URLSessionTask, Result<URL, AFError>) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `request(_:didCreateDestinationURL:)` event.
|
|
|
|
|
- open var requestDidCreateDestinationURL: ((DownloadRequest, URL) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `request(_:didValidateRequest:response:temporaryURL:destinationURL:withResult:)` event.
|
|
|
|
|
- open var requestDidValidateRequestResponseFileURLWithResult: ((DownloadRequest, URLRequest?, HTTPURLResponse, URL?, Request.ValidationResult) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- /// Closure called on the `request(_:didParseResponse:)` event.
|
|
|
|
|
- open var requestDidParseDownloadResponse: ((DownloadRequest, DownloadResponse<URL?, AFError>) -> Void)?
|
|
|
|
|
-
|
|
|
|
|
- public let queue: DispatchQueue
|
|
|
|
|
-
|
|
|
|
|
- /// Creates an instance using the provided queue.
|
|
|
|
|
- ///
|
|
|
|
|
- /// - Parameter queue: `DispatchQueue` on which events will fired. `.main` by default.
|
|
|
|
|
- public init(queue: DispatchQueue = .main) {
|
|
|
|
|
- self.queue = queue
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func urlSession(_ session: URLSession, didBecomeInvalidWithError error: Error?) {
|
|
|
|
|
- sessionDidBecomeInvalidWithError?(session, error)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func urlSession(_ session: URLSession, task: URLSessionTask, didReceive challenge: URLAuthenticationChallenge) {
|
|
|
|
|
- taskDidReceiveChallenge?(session, task, challenge)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func urlSession(_ session: URLSession,
|
|
|
|
|
- task: URLSessionTask,
|
|
|
|
|
- didSendBodyData bytesSent: Int64,
|
|
|
|
|
- totalBytesSent: Int64,
|
|
|
|
|
- totalBytesExpectedToSend: Int64) {
|
|
|
|
|
- taskDidSendBodyData?(session, task, bytesSent, totalBytesSent, totalBytesExpectedToSend)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func urlSession(_ session: URLSession, taskNeedsNewBodyStream task: URLSessionTask) {
|
|
|
|
|
- taskNeedNewBodyStream?(session, task)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func urlSession(_ session: URLSession,
|
|
|
|
|
- task: URLSessionTask,
|
|
|
|
|
- willPerformHTTPRedirection response: HTTPURLResponse,
|
|
|
|
|
- newRequest request: URLRequest) {
|
|
|
|
|
- taskWillPerformHTTPRedirection?(session, task, response, request)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func urlSession(_ session: URLSession, task: URLSessionTask, didFinishCollecting metrics: URLSessionTaskMetrics) {
|
|
|
|
|
- taskDidFinishCollectingMetrics?(session, task, metrics)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func urlSession(_ session: URLSession, task: URLSessionTask, didCompleteWithError error: Error?) {
|
|
|
|
|
- taskDidComplete?(session, task, error)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func urlSession(_ session: URLSession, taskIsWaitingForConnectivity task: URLSessionTask) {
|
|
|
|
|
- taskIsWaitingForConnectivity?(session, task)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func urlSession(_ session: URLSession, dataTask: URLSessionDataTask, didReceive data: Data) {
|
|
|
|
|
- dataTaskDidReceiveData?(session, dataTask, data)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func urlSession(_ session: URLSession, dataTask: URLSessionDataTask, willCacheResponse proposedResponse: CachedURLResponse) {
|
|
|
|
|
- dataTaskWillCacheResponse?(session, dataTask, proposedResponse)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func urlSession(_ session: URLSession,
|
|
|
|
|
- downloadTask: URLSessionDownloadTask,
|
|
|
|
|
- didResumeAtOffset fileOffset: Int64,
|
|
|
|
|
- expectedTotalBytes: Int64) {
|
|
|
|
|
- downloadTaskDidResumeAtOffset?(session, downloadTask, fileOffset, expectedTotalBytes)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func urlSession(_ session: URLSession,
|
|
|
|
|
- downloadTask: URLSessionDownloadTask,
|
|
|
|
|
- didWriteData bytesWritten: Int64,
|
|
|
|
|
- totalBytesWritten: Int64,
|
|
|
|
|
- totalBytesExpectedToWrite: Int64) {
|
|
|
|
|
- downloadTaskDidWriteData?(session, downloadTask, bytesWritten, totalBytesWritten, totalBytesExpectedToWrite)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func urlSession(_ session: URLSession, downloadTask: URLSessionDownloadTask, didFinishDownloadingTo location: URL) {
|
|
|
|
|
- downloadTaskDidFinishDownloadingToURL?(session, downloadTask, location)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- // MARK: Request Events
|
|
|
|
|
-
|
|
|
|
|
- open func request(_ request: Request, didCreateInitialURLRequest urlRequest: URLRequest) {
|
|
|
|
|
- requestDidCreateInitialURLRequest?(request, urlRequest)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func request(_ request: Request, didFailToCreateURLRequestWithError error: AFError) {
|
|
|
|
|
- requestDidFailToCreateURLRequestWithError?(request, error)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func request(_ request: Request, didAdaptInitialRequest initialRequest: URLRequest, to adaptedRequest: URLRequest) {
|
|
|
|
|
- requestDidAdaptInitialRequestToAdaptedRequest?(request, initialRequest, adaptedRequest)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func request(_ request: Request, didFailToAdaptURLRequest initialRequest: URLRequest, withError error: AFError) {
|
|
|
|
|
- requestDidFailToAdaptURLRequestWithError?(request, initialRequest, error)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func request(_ request: Request, didCreateURLRequest urlRequest: URLRequest) {
|
|
|
|
|
- requestDidCreateURLRequest?(request, urlRequest)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func request(_ request: Request, didCreateTask task: URLSessionTask) {
|
|
|
|
|
- requestDidCreateTask?(request, task)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func request(_ request: Request, didGatherMetrics metrics: URLSessionTaskMetrics) {
|
|
|
|
|
- requestDidGatherMetrics?(request, metrics)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func request(_ request: Request, didFailTask task: URLSessionTask, earlyWithError error: AFError) {
|
|
|
|
|
- requestDidFailTaskEarlyWithError?(request, task, error)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func request(_ request: Request, didCompleteTask task: URLSessionTask, with error: AFError?) {
|
|
|
|
|
- requestDidCompleteTaskWithError?(request, task, error)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func requestIsRetrying(_ request: Request) {
|
|
|
|
|
- requestIsRetrying?(request)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func requestDidFinish(_ request: Request) {
|
|
|
|
|
- requestDidFinish?(request)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func requestDidResume(_ request: Request) {
|
|
|
|
|
- requestDidResume?(request)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request(_ request: Request, didResumeTask task: URLSessionTask) {
|
|
|
|
|
- requestDidResumeTask?(request, task)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func requestDidSuspend(_ request: Request) {
|
|
|
|
|
- requestDidSuspend?(request)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request(_ request: Request, didSuspendTask task: URLSessionTask) {
|
|
|
|
|
- requestDidSuspendTask?(request, task)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func requestDidCancel(_ request: Request) {
|
|
|
|
|
- requestDidCancel?(request)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- public func request(_ request: Request, didCancelTask task: URLSessionTask) {
|
|
|
|
|
- requestDidCancelTask?(request, task)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func request(_ request: DataRequest,
|
|
|
|
|
- didValidateRequest urlRequest: URLRequest?,
|
|
|
|
|
- response: HTTPURLResponse,
|
|
|
|
|
- data: Data?,
|
|
|
|
|
- withResult result: Request.ValidationResult) {
|
|
|
|
|
- requestDidValidateRequestResponseDataWithResult?(request, urlRequest, response, data, result)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func request(_ request: DataRequest, didParseResponse response: DataResponse<Data?, AFError>) {
|
|
|
|
|
- requestDidParseResponse?(request, response)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func request(_ request: UploadRequest, didCreateUploadable uploadable: UploadRequest.Uploadable) {
|
|
|
|
|
- requestDidCreateUploadable?(request, uploadable)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func request(_ request: UploadRequest, didFailToCreateUploadableWithError error: AFError) {
|
|
|
|
|
- requestDidFailToCreateUploadableWithError?(request, error)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func request(_ request: UploadRequest, didProvideInputStream stream: InputStream) {
|
|
|
|
|
- requestDidProvideInputStream?(request, stream)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func request(_ request: DownloadRequest, didFinishDownloadingUsing task: URLSessionTask, with result: Result<URL, AFError>) {
|
|
|
|
|
- requestDidFinishDownloadingUsingTaskWithResult?(request, task, result)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func request(_ request: DownloadRequest, didCreateDestinationURL url: URL) {
|
|
|
|
|
- requestDidCreateDestinationURL?(request, url)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func request(_ request: DownloadRequest,
|
|
|
|
|
- didValidateRequest urlRequest: URLRequest?,
|
|
|
|
|
- response: HTTPURLResponse,
|
|
|
|
|
- fileURL: URL?,
|
|
|
|
|
- withResult result: Request.ValidationResult) {
|
|
|
|
|
- requestDidValidateRequestResponseFileURLWithResult?(request,
|
|
|
|
|
- urlRequest,
|
|
|
|
|
- response,
|
|
|
|
|
- fileURL,
|
|
|
|
|
- result)
|
|
|
|
|
- }
|
|
|
|
|
-
|
|
|
|
|
- open func request(_ request: DownloadRequest, didParseResponse response: DownloadResponse<URL?, AFError>) {
|
|
|
|
|
- requestDidParseDownloadResponse?(request, response)
|
|
|
|
|
- }
|
|
|
|
|
-}
|
|
|