@@ -913,7 +913,6 @@ public static IObservable<TSource> TakeUntil<TSource>(this IObservable<TSource>
913
913
/// <typeparam name="T">The type of the elements in the source sequence.</typeparam>
914
914
/// <param name="source">The source.</param>
915
915
/// <returns>An Observable of T and a release mechanism.</returns>
916
- [ SuppressMessage ( "Roslynator" , "RCS1047:Non-asynchronous method name should not end with 'Async'." , Justification = "To avoid naming conflicts." ) ]
917
916
public static IObservable < ( T Value , IDisposable Sync ) > SynchronizeAsync < T > ( this IObservable < T > source ) =>
918
917
Observable . Create < ( T Value , IDisposable Sync ) > ( observer =>
919
918
{
@@ -930,7 +929,7 @@ public static IObservable<TSource> TakeUntil<TSource>(this IObservable<TSource>
930
929
/// <param name="onError">The on error.</param>
931
930
/// <param name="onCompleted">The on completed.</param>
932
931
/// <returns><see cref="IDisposable"/> object used to unsubscribe from the observable sequence.</returns>
933
- public static IDisposable SubscribeSynchronus < T > ( this IObservable < T > source , Func < T , Task > onNext , Action < Exception > onError , Action onCompleted ) =>
932
+ public static IDisposable SubscribeSynchronous < T > ( this IObservable < T > source , Func < T , Task > onNext , Action < Exception > onError , Action onCompleted ) =>
934
933
source . SynchronizeAsync ( ) . Subscribe (
935
934
async observer =>
936
935
{
@@ -948,7 +947,7 @@ public static IDisposable SubscribeSynchronus<T>(this IObservable<T> source, Fun
948
947
/// <param name="onNext">Action to invoke for each element in the observable sequence.</param>
949
948
/// <param name="onError">Action to invoke upon exceptional termination of the observable sequence.</param>
950
949
/// <returns><see cref="IDisposable"/> object used to unsubscribe from the observable sequence.</returns>
951
- public static IDisposable SubscribeSynchronus < T > ( this IObservable < T > source , Func < T , Task > onNext , Action < Exception > onError ) =>
950
+ public static IDisposable SubscribeSynchronous < T > ( this IObservable < T > source , Func < T , Task > onNext , Action < Exception > onError ) =>
952
951
source . SynchronizeAsync ( ) . Subscribe (
953
952
async observer =>
954
953
{
@@ -966,7 +965,7 @@ public static IDisposable SubscribeSynchronus<T>(this IObservable<T> source, Fun
966
965
/// <param name="onCompleted">Action to invoke upon graceful termination of the observable sequence.</param>
967
966
/// <returns><see cref="IDisposable"/> object used to unsubscribe from the observable sequence.</returns>
968
967
/// <exception cref="ArgumentNullException"><paramref name="source"/> or <paramref name="onNext"/> or <paramref name="onCompleted"/> is <c>null</c>.</exception>
969
- public static IDisposable SubscribeSynchronus < T > ( this IObservable < T > source , Func < T , Task > onNext , Action onCompleted ) =>
968
+ public static IDisposable SubscribeSynchronous < T > ( this IObservable < T > source , Func < T , Task > onNext , Action onCompleted ) =>
970
969
source . SynchronizeAsync ( ) . Subscribe (
971
970
async observer =>
972
971
{
@@ -982,7 +981,7 @@ public static IDisposable SubscribeSynchronus<T>(this IObservable<T> source, Fun
982
981
/// <param name="source">Observable sequence to subscribe to.</param>
983
982
/// <param name="onNext">Action to invoke for each element in the observable sequence.</param>
984
983
/// <returns><see cref="IDisposable"/> object used to unsubscribe from the observable sequence.</returns>
985
- public static IDisposable SubscribeSynchronus < T > ( this IObservable < T > source , Func < T , Task > onNext ) =>
984
+ public static IDisposable SubscribeSynchronous < T > ( this IObservable < T > source , Func < T , Task > onNext ) =>
986
985
source . SynchronizeAsync ( ) . Subscribe (
987
986
async observer =>
988
987
{
0 commit comments