I have the following code for mapping ReactiveSwift SignalProducer to Combine Publisher: import Combine import Foundation import ReactiveSwift /// This is a custom Publisher that wraps SignalProducer ...

I am using ReactiveSwift. There are two protocols: CommonProtocol and SpecificProtocol. When I use SpecificProtocol in map function there is an error Type 'any SpecificProtocol' cannot conform to '...

The following code works: import UIKit import ReactiveSwift import ReactiveCocoa class ViewController: UIViewController { let myAction = Action<UIButton, (), Never> { _ in return ...

It seems like a combination of collect(every:on:skipEmpty:discardWhenCompleted:) and collect(count:) in ReactiveSwift. The resulting signal would send an event every n seconds if the count of ...

I have an array of Property<Int>, and I need to reduce them to get sum of the last inputs (it's basically an unread notification counter from different SDK's) and put that into new Property<...

I'm trying to migrate some parts of a project that was initially written in Obj-C. Currently I'm trying to migrate a code that relies heavily on signals. To give you a general idea of what I'm trying ...

Here's my code to convert ReactiveSwift Signal Producers to Combine.Publishers import ReactiveSwift import Combine /// convert SignalProducer<X, Never> -> Publisher<X, Never> public ...

For example, I want to send a request in my viewModel, if the viewModel is dealloc. The request signal should send interrupt event. This is my code func request() -> SignalProducer<Data, Error&...

I am working on a ViewController where I called my viewModel to do a DispatchQueue.async call. After the async task starts and before the end my task ViewController is deinited by pressing the back ...

I feel confused when I see the sample code from ReactiveSwift, because intuitively observer is expected to receive events. Why does Observer is designed to have send(_:) method? // Signal.pipe is a ...

I recently started using swift's Combine (I've used ReactiveCocoa before), I'm wondering if there is a concept of cold and hot signals also in Combine? Dose Publisher is equal to cold signals(...

I have a simple signal, in one of the app components, that returns an array of items: var itemsSignal: Signal<[Item], Never> Those items might contain updates for the data that are rendered on ...

I have the following pipeline setup, and for some reason I can't understand, the second flatMap is skipped: func letsDoThis() -> SignalProducer<(), MyError> { let logError: (MyError) -&...

The following func runs well before I update to Xcode12, I'm new to ReactiveSwift and I don't know how to fix this issue, thanks for you help! Error message: Cannot convert value of type 'Disposable?'...

I have a pipeline in ReactiveSwift for uploads. I want to make sure that even if one of the uploads fail, the rest will not be interrupted. After all of them complete with success or failure, I should ...