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