/
RACSignalSequence.m
79 lines (60 loc) · 1.68 KB
/
RACSignalSequence.m
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
//
// RACSignalSequence.m
// ReactiveCocoa
//
// Created by Justin Spahr-Summers on 2012-11-09.
// Copyright (c) 2012 GitHub, Inc. All rights reserved.
//
#import "RACSignalSequence.h"
#import "RACDisposable.h"
#import "RACReplaySubject.h"
#import "RACSignal+Operations.h"
@interface RACSignalSequence ()
// Replays the signal given on initialization.
@property (nonatomic, strong, readonly) RACReplaySubject *subject;
@end
@implementation RACSignalSequence
#pragma mark Lifecycle
+ (RACSequence *)sequenceWithSignal:(RACSignal *)signal {
RACSignalSequence *seq = [[self alloc] init];
RACReplaySubject *subject = [RACReplaySubject subject];
[signal subscribeNext:^(id value) {
[subject sendNext:value];
} error:^(NSError *error) {
[subject sendError:error];
} completed:^{
[subject sendCompleted];
}];
seq->_subject = subject;
return seq;
}
#pragma mark RACSequence
- (id)head {
id value = [self.subject firstOrDefault:self];
if (value == self) {
return nil;
} else {
return value ?: NSNull.null;
}
}
- (RACSequence *)tail {
RACSequence *sequence = [self.class sequenceWithSignal:[self.subject skip:1]];
sequence.name = self.name;
return sequence;
}
- (NSArray *)array {
return self.subject.toArray;
}
#pragma mark NSObject
- (NSString *)description {
// Synchronously accumulate the values that have been sent so far.
NSMutableArray *values = [NSMutableArray array];
RACDisposable *disposable = [self.subject subscribeNext:^(id value) {
@synchronized (values) {
[values addObject:value ?: NSNull.null];
}
}];
[disposable dispose];
return [NSString stringWithFormat:@"<%@: %p>{ name = %@, values = %@ … }", self.class, self, self.name, values];
}
@end