使用RACSubject对RACSignal的简单用法进行单元测试

(我可能会以完全错误的方式使用它,所以请随意挑战这篇文章的前提.)

我有一个小的RACTest应用程序(听起来很熟悉吗？),我正在尝试进行单元测试.我想测试MPSTicker,它是最基于ReactiveCocoa的组件之一.如果累积标志设置为YES,它有一个每秒发送一次累积值的信号.我添加了一个初始化器来为其递增信号采用自定义信号,而不是仅基于定时器.

我想对MPSTicker的几个行为进行单元测试:

当累加使能且输入递增信号发送新值时,验证其累加信号是否正确递增(即单调增加).

当输入信号发送值时,验证它是否发送相同的值(而不是递增的值).

我添加了一个使用内置计时器来测试第一个增量的测试,并且它按照我的预期工作(尽管我正在寻求改进愚蠢的RACSequence初始化的建议,我做了以获得具有@(1)我想要的值的信号. )

我很难确定我可以向MPSTicker提供哪些输入信号,我可以手动发送值.我想象一个测试:

我尝试使用一个,RACSubject所以我可以使用sendNext:我认为合适的价值,但它不像我期望的那样工作.这是两个破碎的测试:

- (void)testManualTimerTheFirst
{
    // Create a custom tick with one value to send.
    RACSubject *controlledSignal = [RACSubject subject];
    MPSTicker *ticker = [[MPSTicker alloc] initWithTickSource:controlledSignal];
    [ticker.accumulateSignal subscribeNext:^(id x) {
        NSLog(@"%s value is %@", __func__, x);
    }];

    [controlledSignal sendNext:@(2)];
}

- (void)testManualTimerTheSecond
{
    // Create a custom tick with one value to send.
    RACSubject *controlledSignal = [RACSubject subject];
    MPSTicker *ticker = [[MPSTicker alloc] initWithTickSource:controlledSignal];

    BOOL success = NO;
    NSError *error = nil;
    id value = [ticker.accumulateSignal asynchronousFirstOrDefault:nil success:&success error:&error];

    if (!success) {
        XCTAssertTrue(success, @"Signal failed to return a value. Error: %@", error);
    } else {
        XCTAssertNotNil(value, @"Signal returned a nil value.");
        XCTAssertEqualObjects(@(1), value, @"Signal returned an unexpected value.");
    }

    // Send a value.
    [controlledSignal sendNext:@(1)];
}

在testManualTimerTheFirst,我从来没有看到任何价值controlledSignal的sendNext:通过来我subscribeNext:挡.

在testManualTimerTheSecond,我尝试使用该asynchronousFirstOrDefault:调用从信号中获取第一个值,然后在我的主题上手动发送一个值,但该值未通过,并且测试在asynchronousFirstOrDefault:超时时失败.

我在这里错过了什么？