ReactiveKit Bindings/Extensions for Migration

[marcoRS]

Do you have any plans to include or create ReactiveKit type Bindings/Extensions for those of us who want to migrate a ReactiveKit style project to Coroutines?

So something like: mySignal.await() to be able to call within a coroutine function.

[belozierov]

@marcoRS Hi, I don't plan to make any extensions for integration with other libraries but you can do it by yourself. I'm not familiar with ReactiveKit but you can do something like this:

struct SignalCompleteError: Error {}

extension Signal {
	
   func await() throws -> Element {
      var observer: Disposable?
      return try Coroutine.await { (callback: @escaping (Result<Element, Swift.Error>) -> Void) in
         observer = observe { result in
            switch result {
            case .next(let element):
               callback(.success(element))
            case .failed(let error):
               callback(.failure(error))
            case .completed:
               callback(.failure(SignalCompleteError()))
            }
            observer?.dispose()
         }
      }.get()
   }
	
}