@@ -38,7 +38,7 @@ type TaskSeq private () =
38
38
// Convert 'ToXXX' functions
39
39
//
40
40
41
- static member toList ( source : taskSeq < 'T >) = [
41
+ static member toList ( source : TaskSeq < 'T >) = [
42
42
Internal.checkNonNull ( nameof source) source
43
43
let e = source.GetAsyncEnumerator( CancellationToken())
44
44
@@ -49,7 +49,7 @@ type TaskSeq private () =
49
49
e.DisposeAsync() .AsTask() .Wait()
50
50
]
51
51
52
- static member toArray ( source : taskSeq < 'T >) = [|
52
+ static member toArray ( source : TaskSeq < 'T >) = [|
53
53
Internal.checkNonNull ( nameof source) source
54
54
let e = source.GetAsyncEnumerator( CancellationToken())
55
55
@@ -60,7 +60,7 @@ type TaskSeq private () =
60
60
e.DisposeAsync() .AsTask() .Wait()
61
61
|]
62
62
63
- static member toSeq ( source : taskSeq < 'T >) =
63
+ static member toSeq ( source : TaskSeq < 'T >) =
64
64
Internal.checkNonNull ( nameof source) source
65
65
66
66
seq {
@@ -178,21 +178,21 @@ type TaskSeq private () =
178
178
static member initAsync count initializer = Internal.init ( Some count) ( InitActionAsync initializer)
179
179
static member initInfiniteAsync initializer = Internal.init None ( InitActionAsync initializer)
180
180
181
- static member delay ( generator : unit -> taskSeq < 'T >) =
181
+ static member delay ( generator : unit -> TaskSeq < 'T >) =
182
182
{ new IAsyncEnumerable< 'T> with
183
183
member _.GetAsyncEnumerator ( ct ) = generator() .GetAsyncEnumerator( ct)
184
184
}
185
185
186
- static member concat ( sources : taskSeq < # taskSeq < 'T >>) =
186
+ static member concat ( sources : TaskSeq < # TaskSeq < 'T >>) =
187
187
Internal.checkNonNull ( nameof sources) sources
188
188
189
189
taskSeq {
190
190
for ts in sources do
191
191
// no null-check of inner taskseqs, similar to seq
192
- yield ! ( ts :> taskSeq < 'T >)
192
+ yield ! ( ts :> TaskSeq < 'T >)
193
193
}
194
194
195
- static member append ( source1 : taskSeq < 'T >) ( source2 : taskSeq < 'T >) =
195
+ static member append ( source1 : TaskSeq < 'T >) ( source2 : TaskSeq < 'T >) =
196
196
Internal.checkNonNull ( nameof source1) source1
197
197
Internal.checkNonNull ( nameof source2) source2
198
198
@@ -201,7 +201,7 @@ type TaskSeq private () =
201
201
yield ! source2
202
202
}
203
203
204
- static member appendSeq ( source1 : taskSeq < 'T >) ( source2 : seq < 'T >) =
204
+ static member appendSeq ( source1 : TaskSeq < 'T >) ( source2 : seq < 'T >) =
205
205
Internal.checkNonNull ( nameof source1) source1
206
206
Internal.checkNonNull ( nameof source2) source2
207
207
@@ -210,7 +210,7 @@ type TaskSeq private () =
210
210
yield ! source2
211
211
}
212
212
213
- static member prependSeq ( source1 : seq < 'T >) ( source2 : taskSeq < 'T >) =
213
+ static member prependSeq ( source1 : seq < 'T >) ( source2 : TaskSeq < 'T >) =
214
214
Internal.checkNonNull ( nameof source1) source1
215
215
Internal.checkNonNull ( nameof source2) source2
216
216
@@ -223,9 +223,9 @@ type TaskSeq private () =
223
223
// iter/map/collect functions
224
224
//
225
225
226
- static member cast source : taskSeq < 'T > = Internal.map ( SimpleAction( fun ( x : obj ) -> x :?> 'T)) source
226
+ static member cast source : TaskSeq < 'T > = Internal.map ( SimpleAction( fun ( x : obj ) -> x :?> 'T)) source
227
227
static member box source = Internal.map ( SimpleAction box) source
228
- static member unbox < 'U when 'U : struct >( source : taskSeq < obj >) : taskSeq < 'U > = Internal.map ( SimpleAction unbox) source
228
+ static member unbox < 'U when 'U : struct >( source : TaskSeq < obj >) : TaskSeq < 'U > = Internal.map ( SimpleAction unbox) source
229
229
static member iter action source = Internal.iter ( SimpleAction action) source
230
230
static member iteri action source = Internal.iter ( CountableAction action) source
231
231
static member iterAsync action source = Internal.iter ( AsyncSimpleAction action) source
@@ -234,10 +234,10 @@ type TaskSeq private () =
234
234
static member mapi ( mapper : int -> 'T -> 'U ) source = Internal.map ( CountableAction mapper) source
235
235
static member mapAsync mapper source = Internal.map ( AsyncSimpleAction mapper) source
236
236
static member mapiAsync mapper source = Internal.map ( AsyncCountableAction mapper) source
237
- static member collect ( binder : 'T -> #taskSeq <'U>) source = Internal.collect binder source
237
+ static member collect ( binder : 'T -> #TaskSeq <'U>) source = Internal.collect binder source
238
238
static member collectSeq ( binder : 'T -> #seq<'U> ) source = Internal.collectSeq binder source
239
- static member collectAsync ( binder : 'T -> #Task< #taskSeq <'U>>) source : taskSeq < 'U > = Internal.collectAsync binder source
240
- static member collectSeqAsync ( binder : 'T -> #Task< #seq<'U>> ) source : taskSeq < 'U > = Internal.collectSeqAsync binder source
239
+ static member collectAsync ( binder : 'T -> #Task< #TaskSeq <'U>>) source : TaskSeq < 'U > = Internal.collectAsync binder source
240
+ static member collectSeqAsync ( binder : 'T -> #Task< #seq<'U>> ) source : TaskSeq < 'U > = Internal.collectSeqAsync binder source
241
241
242
242
//
243
243
// choosers, pickers and the like
@@ -276,7 +276,7 @@ type TaskSeq private () =
276
276
Internal.tryExactlyOne source
277
277
|> Task.map ( Option.defaultWith ( fun () -> invalidArg ( nameof source) " The input sequence contains more than one element." ))
278
278
279
- static member indexed ( source : taskSeq < 'T >) =
279
+ static member indexed ( source : TaskSeq < 'T >) =
280
280
Internal.checkNonNull ( nameof source) source
281
281
282
282
taskSeq {
0 commit comments