groupwhile

groupWhile.fs

type Stream<'T> = ('T -> unit) -> unit

module Stream =
    let inline groupWhile (pred : 'T -> bool) (source : Stream<'T>) : Stream<'T []> =
        fun k ->
            let ra = new ResizeArray<'T> ()
            let iter (t : 'T) =
                if not <| pred t then
                    k <| ra.ToArray()
                    ra.Clear()
                ra.Add t
    
            source iter
        
[|1 .. 1000|]
|> Streams.ofArray
|> Streams.groupWhile (fun i -> i % 10 <> 0)
|> Streams.toArray