RACSupport

gistfile1.txt

- (RACSignal *)rac_requestWithMethod:(NSString *)method path:(NSString *)path parameters:(id)parameters {
    return [[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        NSError *error;
        NSURLRequest *request = [self.requestSerializer requestWithMethod:method URLString:[[NSURL URLWithString:path relativeToURL:self.baseURL] absoluteString] parameters:parameters error:&error];

        if (error) {
            [subscriber sendError:error];
            return nil;
        }

        NSURLSessionDataTask *task = [self dataTaskWithRequest:request
                                             completionHandler:^(NSURLResponse *response, id responseObject, NSError *error) {
                                                 if (error) {
                                                     NSMutableDictionary *userInfo = [error.userInfo mutableCopy];
                                                     if (responseObject) {
                                                         userInfo[TWAFResponseObjectErrorKey] = responseObject;
                                                     }
                                                     NSError *errorWithRes = [NSError errorWithDomain:error.domain code:error.code userInfo:[userInfo copy]];
                                                     [subscriber sendError:errorWithRes];
                                                 } else {
                                                     [subscriber sendNext:RACTuplePack(response, responseObject)];
                                                     [subscriber sendCompleted];
                                                 }
                                             }];
        [task resume];

        return [RACDisposable disposableWithBlock:^{
            [task cancel];
        }];
    }] replayLazily];
}