Skip to content

Commit

Permalink
fix mixed implementation
Browse files Browse the repository at this point in the history
  • Loading branch information
AngrySKL committed Jun 3, 2024
1 parent c36abf6 commit 02e11ee
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
4 changes: 2 additions & 2 deletions ReactiveMessenger/Implementations/Messenger.cs
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ public IObservable<TSyncMessage> GetSyncMessenger<TSyncMessage>()
throw new InvalidOperationException($"Synchronous message {type.Name} has not been registered!");
}

return (value as Subject<TSyncMessage>).ObserveOn(ThreadPoolScheduler.Instance).AsObservable();
return (value as Subject<TSyncMessage>).AsObservable();
}
#endregion

Expand Down Expand Up @@ -75,7 +75,7 @@ public IObservable<TAsyncMessage> GetAsyncMessenger<TAsyncMessage>()
throw new InvalidOperationException($"Asynchronous message {type.Name} has not been registered!");
}

return (value as Subject<TAsyncMessage>).AsObservable();
return (value as Subject<TAsyncMessage>).ObserveOn(ThreadPoolScheduler.Instance).AsObservable();
}
#endregion
}
2 changes: 1 addition & 1 deletion ReactiveMessenger/ReactiveMessenger.csproj
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@
<GeneratePackageOnBuild>True</GeneratePackageOnBuild>
<RepositoryUrl>https://github.com/AngrySKL/ReactiveMessenger</RepositoryUrl>
<RepositoryType>git</RepositoryType>
<Version>2.0.0</Version>
<Version>2.0.1</Version>
</PropertyGroup>

<ItemGroup>
Expand Down

0 comments on commit 02e11ee

Please sign in to comment.