gistfile1.m

[[[[[[[[[[self.searchTextField
     rac_textSignal]
     filter:^BOOL(NSString *value) {
         return value.length > 2;
     }]
     doNext:^(NSString *x) {
         NSLog(@"[%@] Text Changed: %@", [NSThread currentThread], x);
     }]
     throttle: .6]
     doNext:^(id x) {
         NSLog(@"[%@] Throttle Changed: %@", [NSThread currentThread], x);
     }]
     doNext:^(NSString *x) {
         self.recentList.text = [NSString stringWithFormat:@"%@ \n%@", self.recentList.text, x];
     }]
     subscribeOn:[RACScheduler mainThreadScheduler]]
     flattenMap:^RACStream *(id value) {
         return [self searchTwitter:value];
     }]
     flattenMap:^(NSArray *xs) {
         return [RACSignal createSignal:^ id (id<RACSubscriber> subscriber) {
            for (id x in xs) {
              [subscriber sendNext:x];
            }
            [subscriber sendCompleted];
            return nil;
         }];
     }]
     subscribeNext:^(TwitterInstantSearchModel *x) {
         self.searchResults.text = [NSString stringWithFormat:@"%@ \n%@", self.searchResults.text, x];
         NSLog(@"%@", x);
     }];