草庐IT

swift - 信号 : Collect values over time interval

coder 2023-09-09 原文

这可能是一个微不足道的问题，但我无法为这个看似简单的任务找到解决方案。由于我是 ReactiveSwift 和响应式编程的新手，所以我可能会错过一些明显的东西。

基本上我想做的是这样的:

signal.collect(timeInterval: .seconds(5))

我想从信号中收集特定时间段内的所有值。生成的信号将每 x 秒产生一个事件，其中包含从第一个信号收集的事件数组。

在 ReactiveSwift 中执行此操作的最佳方法是什么？

最佳答案

ReactiveSwift 中没有用于此任务的内置运算符。相反，您可以使用以下方法编写扩展:

import Foundation
import ReactiveSwift
import Result
public extension Signal {
    public func completeAfter(after: TimeInterval, onScheduler : DateSchedulerProtocol = QueueScheduler() ) -> Signal {
        let pipe : (Signal<(), NoError>, ReactiveSwift.Observer<(), NoError>) = Signal<(), NoError>.pipe()
        onScheduler.schedule(after: Date(timeIntervalSinceNow: after)) {
            pipe.1.sendCompleted()
        }
        return Signal { observer in
            return self.observe { event in
                switch event {
                case let .value(value):
                    observer.send(value: value)
                case .completed:
                    observer.sendCompleted()
                case let .failed(error):
                    observer.send(error: error)
                case .interrupted:
                    observer.sendInterrupted()
                }
            }
        }.take(until: pipe.0)
    }

    public func collectUntil(until: TimeInterval) -> Signal<[Value], Error> {
        return self.completeAfter(after: until).collect()
    }
}

然后使用signal.collectUntil(5)方法。

另一种方法是使用 ReactiveSwift 中的 timer 函数。示例(添加到相同的扩展名，如上所述):

public func collectUntil2(until: TimeInterval) -> Signal<[Value], Error> {
    var signal: Signal<(), NoError>? = nil
    timer(interval: until, on: QueueScheduler()).startWithSignal { innerSignal, _ in
        signal = innerSignal.map { _ in () }.take(first: 1)
    }
    return self.take(until: signal!).collect()
}

但是，我不喜欢这种方法，因为它是 SignalProducer 类型提取内部信号的伪造特性。

Signal 类型本身也有 timeout 功能，但是由于它会产生错误，因此很难使用。如何使用它的示例(仍然，添加到相同的扩展):

public func completeOnError() -> Signal<Value, Error> {
    return Signal { observer in
        return self.observe { event in
            switch(event) {
            case .value(let v): observer.send(value: v)
            case .failed(_): observer.sendCompleted()
            case .interrupted: observer.sendInterrupted()
            case .completed: observer.sendCompleted()
            }
        }
    }
}

public func collectUntil3(until: TimeInterval) -> Signal<[Value], Error> {
    return self
        .timeout(after: until,
                 raising: NSError() as! Error,
                 on: QueueScheduler())
        .completeOnError()
        .collect()
}

附言通过选择 3 个选项中的任何一个，请注意传递正确的调度程序或使用正确的调度程序对您的解决方案进行参数化。

关于swift - 信号 : Collect values over time interval，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/42694045/

intervalCollectcodeSignalobserverswiftswift3reactive-cocoareactive-swift

有关swift - 信号 : Collect values over time interval的更多相关文章

  1. Verilog使用inout信号的方法 - 2

    目录一、inout在设计文件中的使用方法1.1、inout的第一种使用方法1.2、inout实现的第二种使用方法1.3、inout使用总结 二、inout在仿真测试中的使用方法一、inout在设计文件中的使用方法在FPGA的设计过程中，有时候会遇到双向信号(既能作为输出，也能作为输入的信号叫双向信号)。比如，IIC总线中的SDA信号就是一个双向信号，QSPIFlash的四线操作的时候四根信号线均为双向信号。在Verilog中用关键字inout定义双向信号，这里总结一下双向信号的处理方法。1.1、inout的第一种使用方法　　实际上，双向信号的本质是由一个三态门组成的，三态门可以输出高电平，低电

  2. ruby - 在 Ruby 中使用 GTK3 自定义信号 - 2

    我想从gtk3中的Widget发出自定义信号。在GTK2中，有一个名为signal_new的函数来创建一个新信号。您可以在此处查看示例:https://github.com/ruby-gnome2/ruby-gnome2/blob/ec373f87e672dbeeaa157f9148d18b34713bb90e/glib2/sample/type-register.rb在GTK3中，这个功能似乎不再可用。那么在ruby​​的GTK3中创建自定义信号的新方法是什么？ 最佳答案 GTK3更改为使用define_signal方法而不是si

  3. ruby - QtRuby 使用参数/参数连接信号和槽 - 2

    我想知道如何连接到带参数的信号(使用Rubyblock)。我知道如何连接到一个不带参数的:myCheckbox.connect(SIGNAL:clicked){doStuff}但是，这不起作用:myCheckbox.connect(SIGNAL:toggle){doStuff}它不起作用，因为切换槽采用参数voidQAbstractButton::toggled(boolchecked)。我怎样才能让它与参数一起工作？谢谢。 最佳答案 对您的问题的简短回答是，您必须使用slots方法声明要连接的插槽的方法签名:classMainGU

  4. ruby - 发送信号时运行代码，但不要在 Ruby 中捕获信号 - 2

    我有在服务器上运行的代码，在服务器硬关闭之前，发送了一个信号SIGTERM让我的代码知道它需要清理。我想在发生这种情况时运行代码并将信号发送回同一个程序，以便任何其他需要清理的代码都可以这样做。我不想捕获信号或改变信号行为，我只需要在我的程序的其余部分解释SIGTERM之前运行一些东西。目前我可以做类似的事情Signal.trap('TERM')doputs"Gracefulshutdown"exitend但如果同一个应用中的多段代码试图做同样的事情，它就不起作用了。例如:Signal.trap('TERM')doputs"Gracefulshutdown"exitendSignal.

  5. ruby - 如何测试 RSpec 中的信号处理，特别是 SIGTERM 的处理？ - 2

    Heroku可能会出于各种原因向您的应用程序发送SIGTERM，因此我创建了一个处理程序来处理一些清理工作，以防发生这种情况。一些谷歌搜索没有给出任何关于如何在RSpec中测试它的答案或示例。这是基本代码:Signal.trap('TERM')docleanupenddefcleanupputs"doingsomecleanupstuff"...exitend当程序收到SIGTERM时，测试调用此清理方法的最佳方法是什么？ 最佳答案 使用Process.kill'TERM',0将信号发送到RSpec并测试调用处理程序。确实，如果信号

  6. ruby - 我怎样才能告诉 unicorn 理解 Heroku 的信号？ - 2

    也许你已经看到了这个......2012-03-07T15:36:25+00:00heroku[web.1]:StoppingprocesswithSIGTERM2012-03-07T15:36:36+00:00heroku[web.1]:StoppingprocesswithSIGKILL2012-03-07T15:36:36+00:00heroku[web.1]:ErrorR12(Exittimeout)->Processfailedtoexitwithin10secondsofSIGTERM2012-03-07T15:36:38+00:00heroku[web.1]:Proces

  7. ruby - Windows 上有哪些 Process.kill 信号可用？ - 2

    来自Process.kill的文档:Sendsthegivensignaltothespecifiedprocessid(s)ifpidispositive.IfpidiszerosignalissenttoallprocesseswhosegroupIDisequaltothegroupIDoftheprocess.signalmaybeanintegersignalnumberoraPOSIXsignalname(eitherwithorwithoutaSIGprefix).Ifsignalisnegative(orstartswithaminussign),killsproces

  8. 互联网时代“陨落”，国家发布元宇宙战略的信号对失业和担心失业的我们带来了什么启迪？ - 2

    互联网这头“猪”真的掉下来了流量红利已经一去不复返了！3年前业界其实已经发出各种密集信号，在当时无论是BAT还是一些经济学家在3年前都已经预测过，互联网的流量模式已经衰竭，并且它将一去不复返。曾经处于互联网大潮的我们这一代人有喜有有悲也有感慨。还在4-5年前不少程序员会发觉在一个地方工作一年再跳一家公司，工资翻倍是至少的。其实这不是能力的表现这只不过是因此我们赶上了互联网流利红利、风投资本红利的“风口”而己。“赶上风口就连老母猪都能上树"用于形容当时的情形一点不为过。可是这个“风”这次是真的过去了，因此这头“猪”掉了下来，而且这次摔了还挺狠，直接给摔成了肉饼。业务模式、生态、环境的变革是时代的

  9. ruby - 如何在 Ruby 中使用信号阻塞 - 2

    如何在Ruby中阻止某些信号？(即sigprocmask，如此处所述:http://www.chemie.fu-berlin.de/chemnet/use/info/libc/libc_21.html#SEC371)这是我的示例代码pid=forkdotrap('INT')doputs"Gracefulshutdown..."puts"goodbye"exit0endloopdothis_could_be_interruptedsomething_that_must_not_be_interruptedthis_could_be_interrupted_tooendendsleep5P

  10. ruby 信号量？ - 2

    我正致力于在Ruby中实现“FairBarbershop”问题。这是一份类作业，但我不是要找任何讲义。我一直在疯狂地搜索，但我似乎无法找到一个信号量的Ruby实现来镜像在C中找到的信号量。我知道有Mutex，这很棒。单一实现，正是那种信号量应该做的。然后是条件变量。我认为这会很好地解决问题，但是看看这些，每个等待调用都需要一个Mutex，在我看来我无法将数值放入信号量(例如，我有七个理发店，3理发师等)。我想我需要一个计数信号量，但我认为Ruby没有(据我所知)在其核心中包含这样一个类，这有点奇怪。谁能帮我指出正确的方向？ 最佳答案

随机推荐