Trouble with throttle operator

[reactivecocoa]

Trouble with throttle operator

[erwald]

It's because [NSThread sleepForTimeInterval:4] blocks the thread completely. If you change the signal block to the following, you'll get the output you expected ("2" and then "4"):

    RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
        NSLog(@"%@", [NSThread currentThread]);

        [subscriber sendNext:@"1"];
        [subscriber sendNext:@"2"];

        dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(4 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
            [subscriber sendNext:@"3"];
            [subscriber sendNext:@"4"];
            [subscriber sendCompleted];
        });

        return [RACDisposable disposableWithBlock:^{
            // ...
        }];
    }];

[AAAboutajedyne]

Thank you for your reply @erwald , yeah correct I just note the presence of "subscribeOn" which i change with deliverOn and I get the expected result. 🕺