RAC wrapping AFNetworking

gistfile1.m

- (RACSignal *)enqueueHTTPRequestWithRequest:(NSURLRequest *)request {
	RACScheduler *scheduler = bee_plugin_rac_scheduler();
	RACSignal *requestSignal = [[RACSignal createSignal:^(id<RACSubscriber> subscriber) {
		AFHTTPRequestOperation *requestOperation = [self HTTPRequestOperationWithRequest:request success:^(AFHTTPRequestOperation *operation, id responseObject) {
			[subscriber sendNext:responseObject];
			[subscriber sendCompleted];
		} failure:^(AFHTTPRequestOperation *operation, NSError *error) {
			[subscriber sendError:error];
		}];

		[self enqueueHTTPRequestOperation:requestOperation];

		return [RACDisposable disposableWithBlock:^{
			[requestOperation cancel];
		}];
	}] deliverOn:scheduler];

	return [[requestSignal replayLazily] setNameWithFormat:@"-enqueueHTTPRequestWithRequest: %@", request];
}