refactor: align generic parameters naming

Author: xperiandri

src/FSharp.Control.R3/Observable.fs

@@ -12,7 +12,7 @@ let inline bind ([<InlineIfLambda>] f : 'T -> Observable<'TNext>) source = Obser
 /// Converts the elements of the sequence to the specified type
 let inline cast<'T, 'CastType> (source) = ObservableExtensions.Cast<'T, 'CastType> (source)
 
-let inline catch ([<InlineIfLambda>] f : 'Exn -> Observable<'TNext>) o = ObservableExtensions.Catch (o, f)
+let inline catch ([<InlineIfLambda>] f : 'Exn -> Observable<'T>) o = ObservableExtensions.Catch (o, f)
 
 /// Concatenates the second observable sequence to the first observable sequence
 /// upn the successful termination of the first
@@ -45,13 +45,13 @@ let inline distinct source = ObservableExtensions.Distinct source
 let inline empty () = Observable.Empty ()
 
 /// Filters the observable elements of a sequence based on a predicate
-let inline filter ([<InlineIfLambda>] f : 't -> bool) source = ObservableExtensions.Where (source, f)
+let inline filter ([<InlineIfLambda>] f : 'T -> bool) source = ObservableExtensions.Where (source, f)
 
 /// Maps the given observable with the given function
-let inline map ([<InlineIfLambda>] f : 't -> 'r) source = ObservableExtensions.Select (source, f)
+let inline map ([<InlineIfLambda>] f : 'T -> 'R) source = ObservableExtensions.Select (source, f)
 
 /// Maps the given observable with the given function and the index of the element
-let inline mapi ([<InlineIfLambda>] f : int -> 't -> 'r) source = ObservableExtensions.Select (source, (fun i x -> f x i))
+let inline mapi ([<InlineIfLambda>] f : int -> 'T -> 'R) source = ObservableExtensions.Select (source, (fun i x -> f x i))
 
 /// Merges two observable sequences into one observable sequence
 let inline merge (source1, source2) = ObservableExtensions.Merge (source1, source2)
@@ -68,7 +68,7 @@ let inline skip (count : int) (source) = ObservableExtensions.Skip (source, coun
 let inline take (count : int) (source) = ObservableExtensions.Take (source, count)
 
 /// Filters the observable elements of a sequence based on a predicate
-let inline where ([<InlineIfLambda>] f : 't -> bool) source = ObservableExtensions.Where (source, f)
+let inline where ([<InlineIfLambda>] f : 'T -> bool) source = ObservableExtensions.Where (source, f)
 
 open System.Runtime.CompilerServices
 open System.Runtime.InteropServices

src/FSharp.Control.R3/TaskObservable.fs

@@ -10,11 +10,11 @@ module Observable =
 
     /// Applies an accumulator function over an observable sequence, returning the
     /// result of the aggregation as a single element in the result sequence
-    let inline aggregate cancellationToken seed ([<InlineIfLambda>] f : 'r -> 't -> 'r) source =
+    let inline aggregate cancellationToken seed ([<InlineIfLambda>] f : 'R -> 'T -> 'R) source =
         ObservableExtensions.AggregateAsync (source, seed, f, cancellationToken)
 
     /// Determines whether all elements of an observable satisfy a predicate
-    let inline all cancellationToken ([<InlineIfLambda>] f : 't -> bool) source = ObservableExtensions.AllAsync (source, f, cancellationToken)
+    let inline all cancellationToken ([<InlineIfLambda>] f : 'T -> bool) source = ObservableExtensions.AllAsync (source, f, cancellationToken)
 
     /// <summary>
     /// Invokes an action for each element in the observable sequence, and propagates all observer
@@ -24,7 +24,7 @@ module Observable =
     /// This method can be used for debugging, logging, etc. of query behavior
     /// by intercepting the message stream to run arbitrary actions for messages on the pipeline.
     /// </remarks>
-    let inline iter cancellationToken ([<InlineIfLambda>] action : 't -> unit) source =
+    let inline iter cancellationToken ([<InlineIfLambda>] action : 'T -> unit) source =
         ObservableExtensions.ForEachAsync (source, action, cancellationToken)
 
     /// Determines whether an observable sequence contains a specified value
@@ -38,8 +38,8 @@ module Observable =
     let length cancellationToken source = ObservableExtensions.CountAsync (source, cancellationToken)
 
     /// Maps the given observable with the given asynchronous function
-    let mapAsync (options : ProcessingOptions) (f : CancellationToken -> 't -> Task<'r>) source =
-        let selector x ct = ValueTask<'r> (f ct x)
+    let mapAsync (options : ProcessingOptions) (f : CancellationToken -> 'T -> Task<'R>) source =
+        let selector x ct = ValueTask<'R> (f ct x)
         ObservableExtensions.SelectAwait (
             source,
             selector,