123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126 |
- #import "UIProgressView+AFNetworking.h"
- #import <objc/runtime.h>
- #if TARGET_OS_IOS || TARGET_OS_TV
- #import "AFURLSessionManager.h"
- static void * AFTaskCountOfBytesSentContext = &AFTaskCountOfBytesSentContext;
- static void * AFTaskCountOfBytesReceivedContext = &AFTaskCountOfBytesReceivedContext;
- #pragma mark -
- @implementation UIProgressView (AFNetworking)
- - (BOOL)af_uploadProgressAnimated {
- return [(NSNumber *)objc_getAssociatedObject(self, @selector(af_uploadProgressAnimated)) boolValue];
- }
- - (void)af_setUploadProgressAnimated:(BOOL)animated {
- objc_setAssociatedObject(self, @selector(af_uploadProgressAnimated), @(animated), OBJC_ASSOCIATION_RETAIN_NONATOMIC);
- }
- - (BOOL)af_downloadProgressAnimated {
- return [(NSNumber *)objc_getAssociatedObject(self, @selector(af_downloadProgressAnimated)) boolValue];
- }
- - (void)af_setDownloadProgressAnimated:(BOOL)animated {
- objc_setAssociatedObject(self, @selector(af_downloadProgressAnimated), @(animated), OBJC_ASSOCIATION_RETAIN_NONATOMIC);
- }
- #pragma mark -
- - (void)setProgressWithUploadProgressOfTask:(NSURLSessionUploadTask *)task
- animated:(BOOL)animated
- {
- if (task.state == NSURLSessionTaskStateCompleted) {
- return;
- }
-
- [task addObserver:self forKeyPath:@"state" options:(NSKeyValueObservingOptions)0 context:AFTaskCountOfBytesSentContext];
- [task addObserver:self forKeyPath:@"countOfBytesSent" options:(NSKeyValueObservingOptions)0 context:AFTaskCountOfBytesSentContext];
- [self af_setUploadProgressAnimated:animated];
- }
- - (void)setProgressWithDownloadProgressOfTask:(NSURLSessionDownloadTask *)task
- animated:(BOOL)animated
- {
- if (task.state == NSURLSessionTaskStateCompleted) {
- return;
- }
-
- [task addObserver:self forKeyPath:@"state" options:(NSKeyValueObservingOptions)0 context:AFTaskCountOfBytesReceivedContext];
- [task addObserver:self forKeyPath:@"countOfBytesReceived" options:(NSKeyValueObservingOptions)0 context:AFTaskCountOfBytesReceivedContext];
- [self af_setDownloadProgressAnimated:animated];
- }
- #pragma mark - NSKeyValueObserving
- - (void)observeValueForKeyPath:(NSString *)keyPath
- ofObject:(id)object
- change:(__unused NSDictionary *)change
- context:(void *)context
- {
- if (context == AFTaskCountOfBytesSentContext || context == AFTaskCountOfBytesReceivedContext) {
- if ([keyPath isEqualToString:NSStringFromSelector(@selector(countOfBytesSent))]) {
- if ([object countOfBytesExpectedToSend] > 0) {
- dispatch_async(dispatch_get_main_queue(), ^{
- [self setProgress:[object countOfBytesSent] / ([object countOfBytesExpectedToSend] * 1.0f) animated:self.af_uploadProgressAnimated];
- });
- }
- }
- if ([keyPath isEqualToString:NSStringFromSelector(@selector(countOfBytesReceived))]) {
- if ([object countOfBytesExpectedToReceive] > 0) {
- dispatch_async(dispatch_get_main_queue(), ^{
- [self setProgress:[object countOfBytesReceived] / ([object countOfBytesExpectedToReceive] * 1.0f) animated:self.af_downloadProgressAnimated];
- });
- }
- }
- if ([keyPath isEqualToString:NSStringFromSelector(@selector(state))]) {
- if ([(NSURLSessionTask *)object state] == NSURLSessionTaskStateCompleted) {
- @try {
- [object removeObserver:self forKeyPath:NSStringFromSelector(@selector(state))];
- if (context == AFTaskCountOfBytesSentContext) {
- [object removeObserver:self forKeyPath:NSStringFromSelector(@selector(countOfBytesSent))];
- }
- if (context == AFTaskCountOfBytesReceivedContext) {
- [object removeObserver:self forKeyPath:NSStringFromSelector(@selector(countOfBytesReceived))];
- }
- }
- @catch (NSException * __unused exception) {}
- }
- }
- }
- }
- @end
- #endif
|