Skip to content

Commit 057ad02

Browse files
committed
cosmetic cleanup
1 parent c05d615 commit 057ad02

1 file changed

Lines changed: 6 additions & 6 deletions

File tree

src/FSharp.Control.AsyncSeq/AsyncSeq.fs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -306,7 +306,7 @@ module AsyncSeq =
306306
///
307307
/// The aggregation function is asynchronous (and the input sequence will
308308
/// be asked for the next element after the processing of an element completes).
309-
let rec scanAsync f (state:'TState) (input : AsyncSeq<'T>) = asyncSeq {
309+
let rec scanAsync f (state:'State) (input : AsyncSeq<'T>) = asyncSeq {
310310
let! v = input
311311
match v with
312312
| Nil -> ()
@@ -343,17 +343,17 @@ module AsyncSeq =
343343
///
344344
/// The aggregation function is asynchronous (and the input sequence will
345345
/// be asked for the next element after the processing of an element completes).
346-
let rec foldAsync f (state:'TState) (input : AsyncSeq<'T>) =
346+
let rec foldAsync f (state:'State) (input : AsyncSeq<'T>) =
347347
input |> scanAsync f state |> lastOrDefault state
348348

349349
/// Same as AsyncSeq.foldAsync, but the specified function is synchronous
350350
/// and returns the result of aggregation immediately.
351-
let rec fold f (state:'TState) (input : AsyncSeq<'T>) =
351+
let rec fold f (state:'State) (input : AsyncSeq<'T>) =
352352
foldAsync (fun st v -> f st v |> async.Return) state input
353353

354354
/// Same as AsyncSeq.scanAsync, but the specified function is synchronous
355355
/// and returns the result of aggregation immediately.
356-
let rec scan f (state:'TState) (input : AsyncSeq<'T>) =
356+
let rec scan f (state:'State) (input : AsyncSeq<'T>) =
357357
scanAsync (fun st v -> f st v |> async.Return) state input
358358

359359
/// Same as AsyncSeq.mapAsync, but the specified function is synchronous
@@ -693,7 +693,7 @@ module AsyncSeq =
693693

694694
/// Interleaves two async sequences into a resulting sequence. The provided
695695
/// sequences are consumed in lock-step.
696-
let interleave =
696+
let interleave (firstSeq: AsyncSeq<'T1>) (secondSeq: AsyncSeq<'T1>) =
697697

698698
let rec left (a:AsyncSeq<'T>) (b:AsyncSeq<'U>) : AsyncSeq<Choice<_,_>> = async {
699699
let! a = a
@@ -707,7 +707,7 @@ module AsyncSeq =
707707
| Cons (a2, t2) -> return Cons (Choice2Of2 a2, left a t2)
708708
| Nil -> return! a |> map Choice1Of2 }
709709

710-
left
710+
left firstSeq secondSeq
711711

712712
/// Buffer items from the async sequence into buffers of a specified size.
713713
/// The last buffer returned may be less than the specified buffer size.

0 commit comments

Comments
 (0)