0

我需要从解析的数据中同步 sqlite 中的几个表。我为它设置了 ReactiveCocoa。但是，我不知道如何在开始下一张表之前等待一张表的同步。

这就是我现在所拥有的：

-(RACSignal *) syncTable:(NSString *)name showProgres:(BOOL)showProgres
{
    @weakify(self);
    NSInteger __block count = 0;

    return [[RACSignal createSignal:^ RACDisposable *(id<RACSubscriber> subscriber)
    {
        PFQuery *query = [PFQuery queryWithClassName:name];
        NSDate *date = [self versionForTable:name];

        if (![name isEqualToString:@"Company"]) {
            [query whereKey:@"x_company" equalTo:[self currentCompany]];
            [query whereKey:@"updatedAt" greaterThan:date];
        } else {
            [query whereKey:@"objectId" equalTo:[self currentCompany].objectId];
        }

        NSArray *objects = [query findObjects];

        if (showProgres) {
            [SVProgressHUD showWithStatus:[NSString stringWithFormat:LOC_SYNC_TABLE, name]];
        }

        for (PFObject *object in objects) {
            [subscriber sendNext:object]; // <-- This is wrong!

            count++;
            if (showProgres) {
                [SVProgressHUD showProgress:count / [objects count] status:name];
            }
        }

        [subscriber sendCompleted];
        return nil;
    }] flattenMap:^RACStream *(PFObject *object) {
        @strongify(self);

        return [self syncRecords:name data:object];
    }];
}

我看不到如何发送每个 PFObject 以及如何处理进度。

PD：这是建议更改的代码：

-(RACSignal *) syncRecords:(NSString *)table data:(PFObject *)data
{
    @weakify(self);

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

        if (![db saveInternal:rs]) {
            NSDictionary *err = @{NSLocalizedDescriptionKey:[rs errorsAsString]};

            [subscriber sendError:[NSError errorWithDomain:LOC_ERROR_SAVE code:0 userInfo:err]];
        } else {
            /* STUFF */
        }        
        [subscriber sendCompleted];

        return nil;
    }];
}

-(RACSignal *) syncTable:(NSString *)name showProgres:(BOOL)showProgres
{
    @weakify(self);
    NSInteger __block count = 0;

    return [[[RACSignal createSignal:^ RACDisposable *(id<RACSubscriber> subscriber)
    {
/* STUFF */
        NSArray *objects = [query findObjects];
        /* If I do this in async way, the concat is not repected*/
/* STUFF */        
        for (PFObject *object in objects) {
            [subscriber sendNext:object];
/* STUFF */
        }
        return nil;
    }] map:^RACStream *(PFObject *object) {
        @strongify(self);

        return [self syncRecords:name data:object];
    }] concat];
}

-(RACSignal *) fullSync
{
    RACSignal *fullSync = [[[[[RACSignal createSignal:^ RACDisposable *(id<RACSubscriber> subscriber)
    {
/* STUFF */
        for (NSString *table in self.tablesFixed) {
            [subscriber sendNext:table];
        }

        [subscriber sendCompleted];

        return nil;
    }] map:^RACStream *(NSString *table) {
        @strongify(self);

        return [self syncTable:table showProgres:YES];
    }] doError:^(NSError *error) {
        DDLogError(@"%@", error);

        [[Db currentDb] rollbackTransaction];
    }] doCompleted:^{
        [[Db currentDb] commitTransaction];
/* STUFF */
    }] concat];


    return fullSync;
}

-(RACSignal *) autoLogin:(PFUser *)user
{
    @weakify(self);

    return [[RACSignal createSignal:^ RACDisposable *(id<RACSubscriber> subscriber)
    {
/* STUFF */
        [subscriber sendNext:user];

        [subscriber sendCompleted];

        return nil;
    }] flattenMap:^RACStream *(id user) {
        @strongify(self);
        return [self fullSync];
    }];
}

-(RACSignal *) login:(NSString *)email pwd:(NSString *)pwd
{
    DDLogInfo(@"Login user %@", email);

    @weakify(self);

    RACSignal *login = [[RACSignal createSignal:^ RACDisposable *(id<RACSubscriber> subscriber)
    {
        [PFUser logInWithUsernameInBackground:email password:pwd block:^(PFUser *user, NSError *error) {            
            if (error) {
                [subscriber sendError:error];
            } else {
                [subscriber sendNext:user];

                [subscriber sendCompleted];
            }
        }];

        return nil;
    }] flattenMap:^RACStream *(id user) {
       @strongify(self);

       return [self autoLogin:user];
    }];

    return login;
}
4

1 回答 1

1

从概念上讲，-flattenMap:最终看起来像这样（a-map:加 a -flatten）：

return [[[RACSignal
    createSignal:^ RACDisposable * (id<RACSubscriber> subscriber) {
        // Generate and send `PFObject`s
        return nil;
    }]
    map:^(PFObject *object) {
        @strongify(self);
        return [self syncRecords:name data:object];
    }]
    flatten];

-flatten将导致同步信号将被尽快订阅，而不管它们的顺序。

您可能不想将它们展平，而是使用-concat，它将保留顺序（因此一次只订阅一个同步）：

return [[[RACSignal
    createSignal:^ RACDisposable * (id<RACSubscriber> subscriber) {
        // Generate and send `PFObject`s
        return nil;
    }]
    map:^(PFObject *object) {
        @strongify(self);
        return [self syncRecords:name data:object];
    }]
    concat];
于 2013-12-05T06:20:11.153 回答