From 828df9f358344472d57e74bd14907f4ab6289c21 Mon Sep 17 00:00:00 2001
From: Monish Syed <er.monish@gmail.com>
Date: Sun, 22 Aug 2021 10:09:06 +0400
Subject: [PATCH] Bump RxSwift to 6.2

---
 WorkflowRxSwift.podspec                          | 2 +-
 WorkflowRxSwift/Sources/ObservableWorkflow.swift | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/WorkflowRxSwift.podspec b/WorkflowRxSwift.podspec
index b6f146176..a1a40d79f 100644
--- a/WorkflowRxSwift.podspec
+++ b/WorkflowRxSwift.podspec
@@ -19,7 +19,7 @@ Pod::Spec.new do |s|
   s.source_files = 'WorkflowRxSwift/Sources/**/*.swift'
 
   s.dependency 'Workflow', "#{s.version}"
-  s.dependency 'RxSwift', '~> 5.1'
+  s.dependency 'RxSwift', '~> 6.2'
 
   s.test_spec 'Tests' do |test_spec|
     test_spec.source_files = 'WorkflowRxSwift/Tests/**/*.swift'
diff --git a/WorkflowRxSwift/Sources/ObservableWorkflow.swift b/WorkflowRxSwift/Sources/ObservableWorkflow.swift
index 36500c01a..b21e469be 100644
--- a/WorkflowRxSwift/Sources/ObservableWorkflow.swift
+++ b/WorkflowRxSwift/Sources/ObservableWorkflow.swift
@@ -40,7 +40,7 @@ struct ObservableWorkflow<Value>: Workflow {
         context.runSideEffect(key: "") { [observable] lifetime in
             let disposable = observable
                 .map { AnyWorkflowAction(sendingOutput: $0) }
-                .subscribeOn(MainScheduler.asyncInstance)
+                .subscribe(on: MainScheduler.asyncInstance)
                 .subscribe(onNext: { value in
                     sink.send(value)
                 })