gpt4 book ai didi

reactive-programming - 如何使用 ReactiveCocoa 对传入信号进行两级排序?

转载 作者:行者123 更新时间:2023-12-04 08:22:51 29 4
gpt4 key购买 nike

我一直在用 ReactiveCocoa 做工具,我遇到了一个有趣的问题。我可以设想任何数量的丑陋、有状态的解决方案,但我非常有信心有一种优雅的、功能性的方式,无论出于何种原因,它都不会在我的脑海中出现。也许你能帮上忙!

这里的输入信号是两部分字符串,如 "<letter>,<number>" .所需的排序规则是,对于给定的字母,输入值应以 <number> 的顺序出现在输出中。 (即 A,2 不应该出现在 A,1 之前)以及所有字母 <letter> 之前输出不应违反 alpha 顺序。 (即,在至少一个以 B 开头的字符串出现之前,不应出现以 A 开头的字符串。)除了这些规则所规定的之外,期望事物将按照提交的顺序到达输出输入。

考虑以下代码:

RACSubject* input = [RACSubject subject];

RACSignal* output = [input <SOME CHAIN OF SIGNAL FUNCTIONS>];

[output subscribeNext:^(id x) { NSLog(@"(%@)",x); }];

[input sendNext: @"A,2"]; // Expect no output
[input sendNext: @"B,4"]; // Expect no output
[input sendNext: @"B,2"]; // Expect no output
[input sendNext: @"B,1"]; // Expect no output
[input sendNext: @"A,1"]; // Expect output: (A,1) (A,2) (B,1) (B,2)
// Note: (A,1) (B,1) (B,2) (A,2) would *not* be right because A,2 appeared on the input before B,1
[input sendNext: @"C,1"]; // Expect output: (C,1)
[input sendNext: @"B,3"]; // Expect output: (B,3) (B,4)
[input sendNext: @"C,3"]; // Expect no output
[input sendNext: @"C,2"]; // Expect output: (C,2) (C,3)

还应该“急切地”生产输出。如果我必须等到输入信号完成才能看到输出,这没有用(当然,除非排序规则规定是这种情况,即如果 A,1 最后出现)

有任何想法吗?

最佳答案

以命令式方式编写它,您可能会使用一些累加器变量,然后循环输入值并根据需要操作累加器。

函数式编程中最接近的并行是扫描(在 ReactiveCocoa 中表示为 -scanWithStart:reduce:)。扫描允许您通过流“线程化”状态并在新输入值到达时使用它。

结果看起来与命令式累积非常相似,除了任何突变都不会逃脱扫描块:

RACSignal *output = [[[[input
map:^(NSString *combo) {
NSArray *components = [combo componentsSeparatedByString:@","];
NSInteger number = [components[1] integerValue];

return RACTuplePack(components[0], @(number));
}]
// We need four state parameters:
// 1. The letter we're waiting for.
// 2. The number we're waiting for.
// 3. Values received that cannot be forwarded until a certain
// letter/number.
// 4. The values to forward at each step.
scanWithStart:RACTuplePack(@"A", @1, @[], @[]) reduce:^(RACTuple *state, RACTuple *letterAndNumber) {
NSString *waitingLetter = state[0];
NSNumber *waitingNumber = state[1];
NSArray *queuedValues = state[2];

// Enqueue this value until we're ready to send it (which may or may not
// occur on this step of the scan).
queuedValues = [queuedValues arrayByAddingObject:letterAndNumber];

if ([letterAndNumber.first isEqual:waitingLetter] && [letterAndNumber.second isEqual:waitingNumber]) {
// Determine the next letter and number.
waitingLetter = …;
waitingNumber = @(waitingNumber.integerValue + 1);

// Sort queuedValues lexically and numerically.
NSArray *forwardValues = …;

// We should no longer have any values queued, since we want to
// forward them all.
return RACTuplePack(waitingLetter, waitingNumber, @[], forwardValues);
} else {
// No values should escape the scan yet. Just pass on our queued
// values.
return RACTuplePack(waitingLetter, waitingNumber, queuedValues, @[]);
}
}]
map:^(RACTuple *state) {
// Convert the array of values into a signal.
NSArray *forwardValues = state.last;
return forwardValues.rac_sequence.signal;
}]
// Forward values from each inner signal in the correct, sorted order.
concat];

为简洁起见,我省略了一些排序逻辑,但很容易用算法的确切细节来填写。

关于reactive-programming - 如何使用 ReactiveCocoa 对传入信号进行两级排序?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/19862609/

29 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com