ReactiveCocoa 链接网络操作失败答案

【问题标题】：ReactiveCocoa chaining network operations failedReactiveCocoa 链接网络操作失败
【发布时间】：2015-04-26 21:28:22
【问题描述】：

我尝试使用 ReactiveCocoa 进行网络操作链接，但失败了。我无法弄清楚我的代码有什么问题。

- (RACSignal *)pg_findObjectsInBackground {
    return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {

        [self findObjectsInBackgroundWithBlock:^(NSArray *objects, NSError *error) {
            if (error) {
                [subscriber sendError:error];
                return;
            }
            [subscriber sendNext:objects];
            [subscriber sendCompleted];
        }];

        return [RACDisposable disposableWithBlock:^{
            [self cancel];
        }];
    }];
}

- (RACSignal *)pg_countObjectsInBackground {
    return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {

        [self countObjectsInBackgroundWithBlock:^(int number, NSError *error) {
            if (error) {
                [subscriber sendError:error];
                return;
            }
            [subscriber sendNext:@(number)];
            [subscriber sendCompleted];
        }];

        return [RACDisposable disposableWithBlock:^{
            [self cancel];
        }];
    }];
}

    __block NSError *_error;
    @weakify(self)
    [[[self.query pg_countObjectsInBackground]flattenMap:^RACStream *(NSNumber *count) {
        @strongify(self)
        self.totalCount = [count integerValue];
        // Second, fetch experiences
        self.query.limit = self.pageSize;
        self.query.skip = self.pageSize * self.currentPage;
        return [self.query pg_findObjectsInBackground];
    }]subscribeNext:^(NSArray *experiences) {
        @strongify(self)
        [self.experiences removeAllObjects];
        [self.experiences addObjectsFromArray:experiences];
    } error:^(NSError *error) {
        _error = error;
    } completed:^{
        @strongify(self)
        if (finishBlock) {
            finishBlock(self, _error);
        }
    }];

第一个请求成功。但是我一回[self.query pg_findObjectsInBackground]，就直接去了disposableWithBlock。

【问题讨论】：

标签： objective-c parse-platform reactive-cocoa

【解决方案1】：

因为您对计数和查找对象操作使用相同的PFQuery 对象，所以当您从flattenMap 方法返回时，查询将被取消。 flattenMap 订阅了新信号（这是相同的信号），我相信这会导致一次性设备触发。一个简单的解决方案是构造一个新的PFQuery 并在flattenMap 块中返回它。

我假设你正在使用 Parse，如果你是，你应该标记它。

【讨论】：