Attempt to stream SPics, not sure if this improves speed
This commit is contained in:
@@ -23,3 +23,11 @@ sortStreamOn :: Ord a => (b -> a) -> StreamOf b -> Stream (Of b) Identity ()
|
||||
sortStreamOn f = S.each . runIdentity . L.purely S.fold_ L.map . S.map g
|
||||
where
|
||||
g x = (f x,x)
|
||||
|
||||
--applyUnzip
|
||||
-- :: (Stream (Of a) IO () -> IO r)
|
||||
-- -> (Stream (Of b) IO () -> IO ())
|
||||
-- -> Stream (Of a) (Stream g IO) ()
|
||||
-- -> IO r
|
||||
--applyUnzip f g s = h s
|
||||
|
||||
|
||||
Reference in New Issue
Block a user