DTObservable Example

ViewController.m

#import <DTObservable/DTObservable.h>


@implementation ViewController

- (void)viewDidLoad {
    [super viewDidLoad];

    DTObservable *exampleObservable = [[DTObservable alloc] init:^(DTSubscriber *subscriber) {
        NSDictionary *profile = @{
                    @"firstName": @"Daniel",
                    @"lastName": @"Thengvall",
                    @"age": @25};

        // Lets pretend something cpu intensive happens here
        [NSThread sleepForTimeInterval:1.f];
        [subscriber complete:profile];
    }];
    
    // if you want to run on a new thread
    //[exampleObservable newThread];
    
    [exampleObservable subscribe:[[DTSubscriber alloc] init:^(NSDictionary *profile) {
        BOOL twentyFive = [profile[@"age"] intValue] == 25;
        NSLog(@"Is age 25? %@", twentyFive ? @"YES" : @"NO");
    } onError:^(NSError *error) {
        NSLog(@"%@", error);
    }]];
}