We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9df32a2 commit 779f9aeCopy full SHA for 779f9ae
1 file changed
src/FSharp.Control.AsyncSeq/AsyncSeq.fs
@@ -1664,10 +1664,9 @@ module AsyncSeq =
1664
let groupByAsync (p:'a -> Async<'k>) (s:AsyncSeq<'a>) : AsyncSeq<'k * AsyncSeq<'a>> = asyncSeq {
1665
let groups = Collections.Generic.Dictionary<'k, Group<'k, 'a>>()
1666
let close group =
1667
- groups.Remove(group.key) |> ignore
1668
AsyncSeqSrcImpl.close group.src
1669
let closeGroups () =
1670
- groups.Values |> Seq.toArray |> Array.iter close
+ groups.Values |> Seq.iter close
1671
use enum = s.GetEnumerator()
1672
let rec go () = asyncSeq {
1673
try
0 commit comments