ReactiveKit Bindings/Extensions for Migration about swiftcoroutine HOT 1 CLOSED

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()
   }
	
}