Skip to content

Commit 13fc11f

Browse files
committed
A bit of cleanup along the way, consistency in coding
1 parent d00dca2 commit 13fc11f

File tree

1 file changed

+4
-10
lines changed

1 file changed

+4
-10
lines changed

src/FSharp.Control.TaskSeq/TaskSeq.fs

Lines changed: 4 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -197,11 +197,8 @@ module TaskSeq =
197197
//
198198

199199
let cast source : taskSeq<'T> = Internal.map (SimpleAction(fun (x: obj) -> x :?> 'T)) source
200-
let box source = Internal.map (SimpleAction(fun x -> box x)) source
201-
202-
let unbox<'U when 'U: struct> (source: taskSeq<obj>) : taskSeq<'U> =
203-
Internal.map (SimpleAction(fun x -> unbox x)) source
204-
200+
let box source = Internal.map (SimpleAction box) source
201+
let unbox<'U when 'U: struct> (source: taskSeq<obj>) : taskSeq<'U> = Internal.map (SimpleAction unbox) source
205202
let iter action source = Internal.iter (SimpleAction action) source
206203
let iteri action source = Internal.iter (CountableAction action) source
207204
let iterAsync action source = Internal.iter (AsyncSimpleAction action) source
@@ -210,12 +207,9 @@ module TaskSeq =
210207
let mapi (mapper: int -> 'T -> 'U) source = Internal.map (CountableAction mapper) source
211208
let mapAsync mapper source = Internal.map (AsyncSimpleAction mapper) source
212209
let mapiAsync mapper source = Internal.map (AsyncCountableAction mapper) source
213-
let collect (binder: 'T -> #IAsyncEnumerable<'U>) source = Internal.collect binder source
210+
let collect (binder: 'T -> #taskSeq<'U>) source = Internal.collect binder source
214211
let collectSeq (binder: 'T -> #seq<'U>) source = Internal.collectSeq binder source
215-
216-
let collectAsync (binder: 'T -> #Task<#IAsyncEnumerable<'U>>) source : taskSeq<'U> =
217-
Internal.collectAsync binder source
218-
212+
let collectAsync (binder: 'T -> #Task<#taskSeq<'U>>) source : taskSeq<'U> = Internal.collectAsync binder source
219213
let collectSeqAsync (binder: 'T -> #Task<#seq<'U>>) source : taskSeq<'U> = Internal.collectSeqAsync binder source
220214

221215
//

0 commit comments

Comments
 (0)