AFHTTPSessionManager+ReactiveCocoa

gistfile1.m

@implementation AFHTTPSessionManager (ReactiveCocoa)

- (RACSignal *)rac_signalForHTTPMethod:(NSString *)method
                              path:(NSString *)path
                        parameters:(NSDictionary *)parameters {
    
    return [RACSignal create:^(id<RACSubscriber> subscriber) {
        NSMutableURLRequest *request = [self.requestSerializer requestWithMethod:method URLString:[[NSURL URLWithString:path relativeToURL:self.baseURL] absoluteString] parameters:parameters error:nil];
        
        __block NSURLSessionDataTask *task = [self dataTaskWithRequest:request completionHandler:^(NSURLResponse * __unused response, id responseObject, NSError *error) {
            if (error) {
                [subscriber sendNext:RACTuplePack(task, responseObject)];
                [subscriber sendCompleted];
            } else {
                [subscriber sendError:error];
            }
        }];
        
        [task resume];
        
        [subscriber.disposable addDisposable:[RACDisposable disposableWithBlock:^{
            [task cancel];
        }]];
    }];
}


@end

if (!error) {
[subscriber sendNext:RACTuplePack(task, responseObject)];
[subscriber sendCompleted];
} else {
[subscriber sendError:error];
}