forked from uasi/AFNetworking-ReactiveCocoa
/
AFHTTPClient+RACSupport.m
104 lines (87 loc) · 4.07 KB
/
AFHTTPClient+RACSupport.m
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
// AFHTTPClient+RACSupport.m
// AFNetworking-ReactiveCocoa
//
// The MIT License (MIT)
//
// Copyright (c) 2013 Tomoki Aonuma <uasi@uasi.jp>
//
// 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 "AFHTTPClient+RACSupport.h"
#import "AFHTTPRequestOperation+RACSupport.h"
#import <ReactiveCocoa/ReactiveCocoa.h>
@implementation AFHTTPClient (RACSupport)
#pragma mark -
- (RACSignal *)rac_enqueueHTTPRequestOperation:(AFHTTPRequestOperation *)requestOperation
{
RACReplaySubject *subject = [RACReplaySubject replaySubjectWithCapacity:1];
[requestOperation rac_setCompletionBlockWithSubject:subject];
[self enqueueHTTPRequestOperation:requestOperation];
return subject;
}
- (RACSignal *)rac_enqueueHTTPRequestOperationWithRequest:(NSURLRequest *)URLRequest
{
AFHTTPRequestOperation *requestOperation = [self HTTPRequestOperationWithRequest:URLRequest success:NULL failure:NULL];
return [self rac_enqueueHTTPRequestOperation:requestOperation];
}
- (RACSignal *)rac_enqueueBatchOfHTTPRequestOperations:(NSArray *)requestOperations
{
RACSignal *signal = [RACSignal merge:[[requestOperations rac_sequence] map:^(AFHTTPRequestOperation *requestOperation) {
RACSubject *subject = [RACReplaySubject replaySubjectWithCapacity:1];
[requestOperation rac_setCompletionBlockWithSubject:subject];
return subject;
}]];
[self enqueueBatchOfHTTPRequestOperations:requestOperations progressBlock:NULL completionBlock:NULL];
return signal;
}
- (RACSignal *)rac_enqueueBatchOfHTTPRequestOperationsWithRequests:(NSArray *)urlRequests
{
NSArray *requestOperations = [[[urlRequests rac_sequence] map:^(NSURLRequest *urlRequest) {
return [self HTTPRequestOperationWithRequest:urlRequest success:NULL failure:NULL];
}] array];
return [self rac_enqueueBatchOfHTTPRequestOperations:requestOperations];
}
#pragma mark -
- (RACSignal *)rac_getPath:(NSString *)path parameters:(NSDictionary *)parameters
{
return [self rac_enqueueRequestWithMethod:@"GET" path:path parameters:parameters];
}
- (RACSignal *)rac_postPath:(NSString *)path parameters:(NSDictionary *)parameters
{
return [self rac_enqueueRequestWithMethod:@"POST" path:path parameters:parameters];
}
- (RACSignal *)rac_putPath:(NSString *)path parameters:(NSDictionary *)parameters
{
return [self rac_enqueueRequestWithMethod:@"PUT" path:path parameters:parameters];
}
- (RACSignal *)rac_deletePath:(NSString *)path parameters:(NSDictionary *)parameters
{
return [self rac_enqueueRequestWithMethod:@"DELETE" path:path parameters:parameters];
}
- (RACSignal *)rac_patchPath:(NSString *)path parameters:(NSDictionary *)parameters
{
return [self rac_enqueueRequestWithMethod:@"PATCH" path:path parameters:parameters];
}
- (RACSignal *)rac_enqueueRequestWithMethod:(NSString *)method
path:(NSString *)path
parameters:(NSDictionary *)parameters
{
NSURLRequest *request = [self requestWithMethod:method path:path parameters:parameters];
return [self rac_enqueueHTTPRequestOperationWithRequest:request];
}
@end