benchmark/LinearOps.hs · streamly

git.iko.soy/streamly

on 6bde698 help sign in

streamly/benchmark/LinearOps.hs

669 lines 22 kB history raw

1-- |

2-- Module : BenchmarkOps

4--

5-- License : MIT

6-- Maintainer : harendra.kumar@gmail.com

8{-# LANGUAGE CPP #-}

9{-# LANGUAGE FlexibleContexts #-}

10{-# LANGUAGE ScopedTypeVariables #-}

11{-# LANGUAGE DeriveAnyClass #-}

12{-# LANGUAGE DeriveGeneric #-}

14module LinearOps where

16import Control.Monad (when)

17import Control.Monad.IO.Class (MonadIO)

18import Data.Functor.Identity (Identity, runIdentity)

19import Data.Maybe (fromJust)

20import Prelude

21 (Monad, Int, (+), ($), (.), return, fmap, even, (>), (<=), (==), (>=),

22 subtract, undefined, Maybe(..), odd, Bool, not, (>>=), mapM_, curry,

23 maxBound, div, IO, compare, Double, fromIntegral, Integer, (<$>),

24 (<*>), flip, (**), (/))

25import qualified Prelude as P

26import qualified Data.Foldable as F

27import qualified GHC.Exts as GHC

28import Control.DeepSeq (NFData)

29import GHC.Generics (Generic)

31import qualified Streamly as S hiding (foldMapWith, runStream)

32import qualified Streamly.Prelude as S

33import qualified Streamly.Pipe as Pipe

35value, maxValue, value2 :: Int

36#ifdef LINEAR_ASYNC

37value = 10000

38#else

39value = 100000

40#endif

41maxValue = value + 1

42value2 = P.round (P.fromIntegral value**(1/2::P.Double)) -- double nested loop

44-------------------------------------------------------------------------------

45-- Benchmark ops

46-------------------------------------------------------------------------------

48-------------------------------------------------------------------------------

49-- Stream generation and elimination

50-------------------------------------------------------------------------------

52type Stream m a = S.SerialT m a

54{-# INLINE source #-}

55source :: (S.MonadAsync m, S.IsStream t) => Int -> t m Int

56source n = sourceUnfoldrM n

58{-# INLINE sourceIntFromTo #-}

59sourceIntFromTo :: (Monad m, S.IsStream t) => Int -> t m Int

60sourceIntFromTo n = S.enumerateFromTo n (n + value)

62{-# INLINE sourceIntFromThenTo #-}

63sourceIntFromThenTo :: (Monad m, S.IsStream t) => Int -> t m Int

64sourceIntFromThenTo n = S.enumerateFromThenTo n (n + 1) (n + value)

66{-# INLINE sourceFracFromTo #-}

67sourceFracFromTo :: (Monad m, S.IsStream t) => Int -> t m Double

68sourceFracFromTo n =

69 S.enumerateFromTo (fromIntegral n) (fromIntegral (n + value))

71{-# INLINE sourceFracFromThenTo #-}

72sourceFracFromThenTo :: (Monad m, S.IsStream t) => Int -> t m Double

73sourceFracFromThenTo n = S.enumerateFromThenTo (fromIntegral n)

74 (fromIntegral n + 1.0001) (fromIntegral (n + value))

76{-# INLINE sourceIntegerFromStep #-}

77sourceIntegerFromStep :: (Monad m, S.IsStream t) => Int -> t m Integer

78sourceIntegerFromStep n =

79 S.take value $ S.enumerateFromThen (fromIntegral n) (fromIntegral n + 1)

81{-# INLINE sourceFromList #-}

82sourceFromList :: (Monad m, S.IsStream t) => Int -> t m Int

83sourceFromList n = S.fromList [n..n+value]

85{-# INLINE sourceFromListM #-}

86sourceFromListM :: (S.MonadAsync m, S.IsStream t) => Int -> t m Int

87sourceFromListM n = S.fromListM (Prelude.fmap return [n..n+value])

89{-# INLINE sourceFromIndices #-}

90sourceFromIndices :: (Monad m, S.IsStream t) => Int -> t m Int

91sourceFromIndices n = S.take value $ S.fromIndices (+ n)

93{-# INLINE sourceFromIndicesM #-}

94sourceFromIndicesM :: (S.MonadAsync m, S.IsStream t) => Int -> t m Int

95sourceFromIndicesM n = S.take value $ S.fromIndicesM (Prelude.fmap return (+ n))

97{-# INLINE sourceFromFoldable #-}

98sourceFromFoldable :: S.IsStream t => Int -> t m Int

99sourceFromFoldable n = S.fromFoldable [n..n+value]

100

101{-# INLINE sourceFromFoldableM #-}

102sourceFromFoldableM :: (S.IsStream t, S.MonadAsync m) => Int -> t m Int

103sourceFromFoldableM n = S.fromFoldableM (Prelude.fmap return [n..n+value])

104

105{-# INLINE sourceFoldMapWith #-}

106sourceFoldMapWith :: (S.IsStream t, S.Semigroup (t m Int))

107 => Int -> t m Int

108sourceFoldMapWith n = S.foldMapWith (S.<>) S.yield [n..n+value]

109

110{-# INLINE sourceFoldMapWithM #-}

111sourceFoldMapWithM :: (S.IsStream t, Monad m, S.Semigroup (t m Int))

112 => Int -> t m Int

113sourceFoldMapWithM n = S.foldMapWith (S.<>) (S.yieldM . return) [n..n+value]

114

115{-# INLINE sourceFoldMapM #-}

116sourceFoldMapM :: (S.IsStream t, Monad m, P.Monoid (t m Int))

117 => Int -> t m Int

118sourceFoldMapM n = F.foldMap (S.yieldM . return) [n..n+value]

119

120{-# INLINE sourceUnfoldr #-}

121sourceUnfoldr :: (Monad m, S.IsStream t) => Int -> t m Int

122sourceUnfoldr n = S.unfoldr step n

123 where

124 step cnt =

125 if cnt > n + value

126 then Nothing

127 else Just (cnt, cnt + 1)

128

129{-# INLINE sourceUnfoldrN #-}

130sourceUnfoldrN :: (Monad m, S.IsStream t) => Int -> Int -> t m Int

131sourceUnfoldrN upto start = S.unfoldr step start

132 where

133 step cnt =

134 if cnt > start + upto

135 then Nothing

136 else Just (cnt, cnt + 1)

137

138{-# INLINE sourceUnfoldrM #-}

139sourceUnfoldrM :: (S.IsStream t, S.MonadAsync m) => Int -> t m Int

140sourceUnfoldrM n = S.unfoldrM step n

141 where

142 step cnt =

143 if cnt > n + value

144 then return Nothing

145 else return (Just (cnt, cnt + 1))

146

147{-# INLINE sourceUnfoldrMN #-}

148sourceUnfoldrMN :: (S.IsStream t, S.MonadAsync m) => Int -> Int -> t m Int

149sourceUnfoldrMN upto start = S.unfoldrM step start

150 where

151 step cnt =

152 if cnt > start + upto

153 then return Nothing

154 else return (Just (cnt, cnt + 1))

155

156{-# INLINE sourceUnfoldrMAction #-}

157sourceUnfoldrMAction :: (S.IsStream t, S.MonadAsync m) => Int -> t m (m Int)

158sourceUnfoldrMAction n = S.serially $ S.unfoldrM step n

159 where

160 step cnt =

161 if cnt > n + value

162 then return Nothing

163 else return (Just (return cnt, cnt + 1))

164

165-------------------------------------------------------------------------------

166-- Pure stream generation

167-------------------------------------------------------------------------------

168

169{-# INLINE sourceIsList #-}

170sourceIsList :: Int -> S.SerialT Identity Int

171sourceIsList n = GHC.fromList [n..n+value]

172

173{-# INLINE sourceIsString #-}

174sourceIsString :: Int -> S.SerialT Identity P.Char

175sourceIsString n = GHC.fromString (P.replicate (n + value) 'a')

176

177-------------------------------------------------------------------------------

178-- Elimination

179-------------------------------------------------------------------------------

180

181{-# INLINE runStream #-}

182runStream :: Monad m => Stream m a -> m ()

183runStream = S.drain

184

185{-# INLINE toList #-}

186toList :: Monad m => Stream m Int -> m [Int]

187

188{-# INLINE head #-}

189{-# INLINE last #-}

190{-# INLINE maximum #-}

191{-# INLINE minimum #-}

192{-# INLINE find #-}

193{-# INLINE findIndex #-}

194{-# INLINE elemIndex #-}

195{-# INLINE foldl1'Reduce #-}

196head, last, minimum, maximum, find, findIndex, elemIndex, foldl1'Reduce

197 :: Monad m => Stream m Int -> m (Maybe Int)

198

199{-# INLINE minimumBy #-}

200{-# INLINE maximumBy #-}

201minimumBy, maximumBy :: Monad m => Stream m Int -> m (Maybe Int)

202

203{-# INLINE foldl'Reduce #-}

204{-# INLINE foldl'ReduceMap #-}

205{-# INLINE foldlM'Reduce #-}

206{-# INLINE foldrMReduce #-}

207{-# INLINE length #-}

208{-# INLINE sum #-}

209{-# INLINE product #-}

210foldl'Reduce, foldl'ReduceMap, foldlM'Reduce, foldrMReduce, length, sum, product

211 :: Monad m

212 => Stream m Int -> m Int

213

214{-# INLINE foldl'Build #-}

215{-# INLINE foldlM'Build #-}

216{-# INLINE foldrMBuild #-}

217foldrMBuild, foldl'Build, foldlM'Build

218 :: Monad m

219 => Stream m Int -> m [Int]

220

221{-# INLINE all #-}

222{-# INLINE any #-}

223{-# INLINE and #-}

224{-# INLINE or #-}

225{-# INLINE null #-}

226{-# INLINE elem #-}

227{-# INLINE notElem #-}

228null, elem, notElem, all, any, and, or :: Monad m => Stream m Int -> m Bool

229

230{-# INLINE toNull #-}

231toNull :: Monad m => (t m a -> S.SerialT m a) -> t m a -> m ()

232toNull t = runStream . t

233

234{-# INLINE uncons #-}

235uncons :: Monad m => Stream m Int -> m ()

236uncons s = do

237 r <- S.uncons s

238 case r of

239 Nothing -> return ()

240 Just (_, t) -> uncons t

241

242{-# INLINE init #-}

243init :: Monad m => Stream m a -> m ()

244init s = S.init s >>= Prelude.mapM_ S.drain

245

246{-# INLINE tail #-}

247tail :: Monad m => Stream m a -> m ()

248tail s = S.tail s >>= Prelude.mapM_ tail

249

250{-# INLINE nullHeadTail #-}

251nullHeadTail :: Monad m => Stream m Int -> m ()

252nullHeadTail s = do

253 r <- S.null s

254 when (not r) $ do

255 _ <- S.head s

256 S.tail s >>= Prelude.mapM_ nullHeadTail

257

258{-# INLINE mapM_ #-}

259mapM_ :: Monad m => Stream m Int -> m ()

260mapM_ = S.mapM_ (\_ -> return ())

261

262toList = S.toList

263

264{-

265{-# INLINE toRevList #-}

266toRevList :: Monad m => Stream m Int -> m [Int]

267toRevList = S.toRevList

268-}

269

270foldrMBuild = S.foldrM (\x xs -> xs >>= return . (x :)) (return [])

271foldl'Build = S.foldl' (flip (:)) []

272foldlM'Build = S.foldlM' (\xs x -> return $ x : xs) []

273

274foldrMReduce = S.foldrM (\x xs -> xs >>= return . (x +)) (return 0)

275foldl'Reduce = S.foldl' (+) 0

276foldl'ReduceMap = P.fmap (+1) . S.foldl' (+) 0

277foldl1'Reduce = S.foldl1' (+)

278foldlM'Reduce = S.foldlM' (\xs a -> return $ a + xs) 0

279

280last = S.last

281null = S.null

282head = S.head

283elem = S.elem maxValue

284notElem = S.notElem maxValue

285length = S.length

286all = S.all (<= maxValue)

287any = S.any (> maxValue)

288and = S.and . S.map (<= maxValue)

289or = S.or . S.map (> maxValue)

290find = S.find (== maxValue)

291findIndex = S.findIndex (== maxValue)

292elemIndex = S.elemIndex maxValue

293maximum = S.maximum

294minimum = S.minimum

295sum = S.sum

296product = S.product

297minimumBy = S.minimumBy compare

298maximumBy = S.maximumBy compare

299

300-------------------------------------------------------------------------------

301-- Transformation

302-------------------------------------------------------------------------------

303

304{-# INLINE transform #-}

305transform :: Monad m => Stream m a -> m ()

306transform = runStream

307

308{-# INLINE composeN #-}

309composeN

310 :: MonadIO m

311 => Int -> (Stream m Int -> Stream m Int) -> Stream m Int -> m ()

312composeN n f =

313 case n of

314 1 -> transform . f

315 2 -> transform . f . f

316 3 -> transform . f . f . f

317 4 -> transform . f . f . f . f

318 _ -> undefined

319

320-- polymorphic stream version of composeN

321{-# INLINE composeN' #-}

322composeN'

323 :: (S.IsStream t, Monad m)

324 => Int -> (t m Int -> Stream m Int) -> t m Int -> m ()

325composeN' n f =

326 case n of

327 1 -> transform . f

328 2 -> transform . f . S.adapt . f

329 3 -> transform . f . S.adapt . f . S.adapt . f

330 4 -> transform . f . S.adapt . f . S.adapt . f . S.adapt . f

331 _ -> undefined

332

333{-# INLINE scan #-}

334{-# INLINE scanl1' #-}

335{-# INLINE map #-}

336{-# INLINE fmap #-}

337{-# INLINE mapMaybe #-}

338{-# INLINE filterEven #-}

339{-# INLINE filterAllOut #-}

340{-# INLINE filterAllIn #-}

341{-# INLINE takeOne #-}

342{-# INLINE takeAll #-}

343{-# INLINE takeWhileTrue #-}

344{-# INLINE takeWhileMTrue #-}

345{-# INLINE dropOne #-}

346{-# INLINE dropAll #-}

347{-# INLINE dropWhileTrue #-}

348{-# INLINE dropWhileMTrue #-}

349{-# INLINE dropWhileFalse #-}

350{-# INLINE findIndices #-}

351{-# INLINE elemIndices #-}

352{-# INLINE insertBy #-}

353{-# INLINE deleteBy #-}

354{-# INLINE reverse #-}

355{-# INLINE reverse' #-}

356{-# INLINE foldrS #-}

357{-# INLINE foldrSMap #-}

358{-# INLINE foldrT #-}

359{-# INLINE foldrTMap #-}

360scan, scanl1', map, fmap, mapMaybe, filterEven, filterAllOut,

361 filterAllIn, takeOne, takeAll, takeWhileTrue, takeWhileMTrue, dropOne,

362 dropAll, dropWhileTrue, dropWhileMTrue, dropWhileFalse,

363 findIndices, elemIndices, insertBy, deleteBy, reverse, reverse',

364 foldrS, foldrSMap, foldrT, foldrTMap

365 :: MonadIO m

366 => Int -> Stream m Int -> m ()

367

368{-# INLINE mapMaybeM #-}

369{-# INLINE intersperse #-}

370mapMaybeM, intersperse :: S.MonadAsync m => Int -> Stream m Int -> m ()

371

372{-# INLINE mapM #-}

373{-# INLINE transformMapM #-}

374{-# INLINE transformComposeMapM #-}

375{-# INLINE transformTeeMapM #-}

376{-# INLINE transformZipMapM #-}

377{-# INLINE map' #-}

378{-# INLINE fmap' #-}

379mapM, map', transformMapM, transformComposeMapM, transformTeeMapM,

380 transformZipMapM :: (S.IsStream t, S.MonadAsync m)

381 => (t m Int -> S.SerialT m Int) -> Int -> t m Int -> m ()

382

383fmap' :: (S.IsStream t, S.MonadAsync m, P.Functor (t m))

384 => (t m Int -> S.SerialT m Int) -> Int -> t m Int -> m ()

385

386{-# INLINE sequence #-}

387sequence :: (S.IsStream t, S.MonadAsync m)

388 => (t m Int -> S.SerialT m Int) -> t m (m Int) -> m ()

389

390scan n = composeN n $ S.scanl' (+) 0

391scanl1' n = composeN n $ S.scanl1' (+)

392fmap n = composeN n $ Prelude.fmap (+1)

393fmap' t n = composeN' n $ t . Prelude.fmap (+1)

394map n = composeN n $ S.map (+1)

395map' t n = composeN' n $ t . S.map (+1)

396mapM t n = composeN' n $ t . S.mapM return

397

398transformMapM t n = composeN' n $ t . S.transform (Pipe.mapM return)

399transformComposeMapM t n = composeN' n $ t . S.transform

400 (Pipe.mapM (\x -> return (x + 1))

401 `Pipe.compose` Pipe.mapM (\x -> return (x + 2)))

402transformTeeMapM t n = composeN' n $ t . S.transform

403 (Pipe.mapM (\x -> return (x + 1))

404 `Pipe.tee` Pipe.mapM (\x -> return (x + 2)))

405transformZipMapM t n = composeN' n $ t . S.transform

406 (Pipe.zipWith (+) (Pipe.mapM (\x -> return (x + 1)))

407 (Pipe.mapM (\x -> return (x + 2))))

408

409mapMaybe n = composeN n $ S.mapMaybe

410 (\x -> if Prelude.odd x then Nothing else Just x)

411mapMaybeM n = composeN n $ S.mapMaybeM

412 (\x -> if Prelude.odd x then return Nothing else return $ Just x)

413sequence t = transform . t . S.sequence

414filterEven n = composeN n $ S.filter even

415filterAllOut n = composeN n $ S.filter (> maxValue)

416filterAllIn n = composeN n $ S.filter (<= maxValue)

417takeOne n = composeN n $ S.take 1

418takeAll n = composeN n $ S.take maxValue

419takeWhileTrue n = composeN n $ S.takeWhile (<= maxValue)

420takeWhileMTrue n = composeN n $ S.takeWhileM (return . (<= maxValue))

421dropOne n = composeN n $ S.drop 1

422dropAll n = composeN n $ S.drop maxValue

423dropWhileTrue n = composeN n $ S.dropWhile (<= maxValue)

424dropWhileMTrue n = composeN n $ S.dropWhileM (return . (<= maxValue))

425dropWhileFalse n = composeN n $ S.dropWhile (> maxValue)

426findIndices n = composeN n $ S.findIndices (== maxValue)

427elemIndices n = composeN n $ S.elemIndices maxValue

428intersperse n = composeN n $ S.intersperse maxValue

429insertBy n = composeN n $ S.insertBy compare maxValue

430deleteBy n = composeN n $ S.deleteBy (>=) maxValue

431reverse n = composeN n $ S.reverse

432reverse' n = composeN n $ S.reverse'

433foldrS n = composeN n $ S.foldrS S.cons S.nil

434foldrSMap n = composeN n $ S.foldrS (\x xs -> x + 1 `S.cons` xs) S.nil

435foldrT n = composeN n $ S.foldrT S.cons S.nil

436foldrTMap n = composeN n $ S.foldrT (\x xs -> x + 1 `S.cons` xs) S.nil

437

438-------------------------------------------------------------------------------

439-- Iteration

440-------------------------------------------------------------------------------

441

442iterStreamLen, maxIters :: Int

443iterStreamLen = 10

444maxIters = 10000

445

446{-# INLINE iterateSource #-}

447iterateSource

448 :: S.MonadAsync m

449 => (Stream m Int -> Stream m Int) -> Int -> Int -> Stream m Int

450iterateSource g i n = f i (sourceUnfoldrMN iterStreamLen n)

451 where

452 f (0 :: Int) m = g m

453 f x m = g (f (x P.- 1) m)

454

455{-# INLINE iterateMapM #-}

456{-# INLINE iterateScan #-}

457{-# INLINE iterateScanl1 #-}

458{-# INLINE iterateFilterEven #-}

459{-# INLINE iterateTakeAll #-}

460{-# INLINE iterateDropOne #-}

461{-# INLINE iterateDropWhileFalse #-}

462{-# INLINE iterateDropWhileTrue #-}

463iterateMapM, iterateScan, iterateScanl1, iterateFilterEven, iterateTakeAll,

464 iterateDropOne, iterateDropWhileFalse, iterateDropWhileTrue

465 :: S.MonadAsync m

466 => Int -> Stream m Int

467

468-- this is quadratic

469iterateScan = iterateSource (S.scanl' (+) 0) (maxIters `div` 10)

470-- so is this

471iterateScanl1 = iterateSource (S.scanl1' (+)) (maxIters `div` 10)

472

473iterateMapM = iterateSource (S.mapM return) maxIters

474iterateFilterEven = iterateSource (S.filter even) maxIters

475iterateTakeAll = iterateSource (S.take maxValue) maxIters

476iterateDropOne = iterateSource (S.drop 1) maxIters

477iterateDropWhileFalse = iterateSource (S.dropWhile (> maxValue)) maxIters

478iterateDropWhileTrue = iterateSource (S.dropWhile (<= maxValue)) maxIters

479

480-------------------------------------------------------------------------------

481-- Zipping and concat

482-------------------------------------------------------------------------------

483

484{-# INLINE zip #-}

485{-# INLINE zipM #-}

486{-# INLINE mergeBy #-}

487zip, zipM, mergeBy :: Monad m => Stream m Int -> m ()

488

489zip src = do

490 r <- S.tail src

491 let src1 = fromJust r

492 transform (S.zipWith (,) src src1)

493zipM src = do

494 r <- S.tail src

495 let src1 = fromJust r

496 transform (S.zipWithM (curry return) src src1)

497

498mergeBy src = do

499 r <- S.tail src

500 let src1 = fromJust r

501 transform (S.mergeBy P.compare src src1)

502

503{-# INLINE isPrefixOf #-}

504{-# INLINE isSubsequenceOf #-}

505isPrefixOf, isSubsequenceOf :: Monad m => Stream m Int -> m Bool

506

507isPrefixOf src = S.isPrefixOf src src

508isSubsequenceOf src = S.isSubsequenceOf src src

509

510{-# INLINE stripPrefix #-}

511stripPrefix :: Monad m => Stream m Int -> m ()

512stripPrefix src = do

513 _ <- S.stripPrefix src src

514 return ()

515

516{-# INLINE zipAsync #-}

517{-# INLINE zipAsyncM #-}

518{-# INLINE zipAsyncAp #-}

519zipAsync, zipAsyncAp, zipAsyncM :: S.MonadAsync m => Stream m Int -> m ()

520

521zipAsync src = do

522 r <- S.tail src

523 let src1 = fromJust r

524 transform (S.zipAsyncWith (,) src src1)

525

526zipAsyncM src = do

527 r <- S.tail src

528 let src1 = fromJust r

529 transform (S.zipAsyncWithM (curry return) src src1)

530

531zipAsyncAp src = do

532 r <- S.tail src

533 let src1 = fromJust r

534 transform (S.zipAsyncly $ (,) <$> S.serially src

535 <*> S.serially src1)

536

537{-# INLINE eqBy #-}

538eqBy :: (Monad m, P.Eq a) => Stream m a -> m P.Bool

539eqBy src = S.eqBy (==) src src

540

541{-# INLINE cmpBy #-}

542cmpBy :: (Monad m, P.Ord a) => Stream m a -> m P.Ordering

543cmpBy src = S.cmpBy P.compare src src

544

545-- The worst case for concatMap, concat a 1 element stream n times.

546{-# INLINE concatMap #-}

547concatMap :: S.MonadAsync m => Int -> Stream m Int

548concatMap n = S.concatMap (\_ -> sourceUnfoldrMN 1 n)

549 (sourceUnfoldrMN value n)

550

551{-# INLINE concatMapPure1xN #-}

552concatMapPure1xN :: S.MonadAsync m => Int -> Stream m Int

553concatMapPure1xN n = S.concatMap (\_ -> sourceUnfoldrN 1 n)

554 (sourceUnfoldrN value n)

555

556-- We use a (sqrt n) element stream as source and then generate and concat a

557-- (sqrt n) element stream for each element of the source to produce an n

558-- element stream.

559{-# INLINE concatMapNxN #-}

560concatMapNxN :: S.MonadAsync m => Int -> Stream m Int

561concatMapNxN n = S.concatMap (\_ -> sourceUnfoldrMN value2 n)

562 (sourceUnfoldrMN value2 n)

563

564{-# INLINE concatMapRepl4xN #-}

565concatMapRepl4xN :: S.MonadAsync m => Int -> Stream m Int

566concatMapRepl4xN n = S.concatMap (S.replicate 4)

567 (sourceUnfoldrMN (value `div` 4) n)

568

569-------------------------------------------------------------------------------

570-- Mixed Composition

571-------------------------------------------------------------------------------

572

573{-# INLINE scanMap #-}

574{-# INLINE dropMap #-}

575{-# INLINE dropScan #-}

576{-# INLINE takeDrop #-}

577{-# INLINE takeScan #-}

578{-# INLINE takeMap #-}

579{-# INLINE filterDrop #-}

580{-# INLINE filterTake #-}

581{-# INLINE filterScan #-}

582{-# INLINE filterScanl1 #-}

583{-# INLINE filterMap #-}

584scanMap, dropMap, dropScan, takeDrop, takeScan, takeMap, filterDrop,

585 filterTake, filterScan, filterScanl1, filterMap

586 :: MonadIO m => Int -> Stream m Int -> m ()

587

588scanMap n = composeN n $ S.map (subtract 1) . S.scanl' (+) 0

589dropMap n = composeN n $ S.map (subtract 1) . S.drop 1

590dropScan n = composeN n $ S.scanl' (+) 0 . S.drop 1

591takeDrop n = composeN n $ S.drop 1 . S.take maxValue

592takeScan n = composeN n $ S.scanl' (+) 0 . S.take maxValue

593takeMap n = composeN n $ S.map (subtract 1) . S.take maxValue

594filterDrop n = composeN n $ S.drop 1 . S.filter (<= maxValue)

595filterTake n = composeN n $ S.take maxValue . S.filter (<= maxValue)

596filterScan n = composeN n $ S.scanl' (+) 0 . S.filter (<= maxBound)

597filterScanl1 n = composeN n $ S.scanl1' (+) . S.filter (<= maxBound)

598filterMap n = composeN n $ S.map (subtract 1) . S.filter (<= maxValue)

599

600data Pair a b = Pair !a !b deriving (Generic, NFData)

601

602{-# INLINE sumProductFold #-}

603sumProductFold :: Monad m => Stream m Int -> m (Int, Int)

604sumProductFold = S.foldl' (\(s,p) x -> (s + x, p P.* x)) (0,1)

605

606{-# INLINE sumProductScan #-}

607sumProductScan :: Monad m => Stream m Int -> m (Pair Int Int)

608sumProductScan = S.foldl' (\(Pair _ p) (s0,x) -> Pair s0 (p P.* x)) (Pair 0 1)

609 . S.scanl' (\(s,_) x -> (s + x,x)) (0,0)

610

611-------------------------------------------------------------------------------

612-- Pure stream operations

613-------------------------------------------------------------------------------

614

615{-# INLINE eqInstance #-}

616eqInstance :: Stream Identity Int -> Bool

617eqInstance src = src == src

618

619{-# INLINE eqInstanceNotEq #-}

620eqInstanceNotEq :: Stream Identity Int -> Bool

621eqInstanceNotEq src = src P./= src

622

623{-# INLINE ordInstance #-}

624ordInstance :: Stream Identity Int -> Bool

625ordInstance src = src P.< src

626

627{-# INLINE ordInstanceMin #-}

628ordInstanceMin :: Stream Identity Int -> Stream Identity Int

629ordInstanceMin src = P.min src src

630

631{-# INLINE showInstance #-}

632showInstance :: Stream Identity Int -> P.String

633showInstance src = P.show src

634

635{-# INLINE showInstanceList #-}

636showInstanceList :: [Int] -> P.String

637showInstanceList src = P.show src

638

639{-# INLINE readInstance #-}

640readInstance :: P.String -> Stream Identity Int

641readInstance str =

642 let r = P.reads str

643 in case r of

644 [(x,"")] -> x

645 _ -> P.error "readInstance: no parse"

646

647{-# INLINE readInstanceList #-}

648readInstanceList :: P.String -> [Int]

649readInstanceList str =

650 let r = P.reads str

651 in case r of

652 [(x,"")] -> x

653 _ -> P.error "readInstance: no parse"

654

655{-# INLINE pureFoldl' #-}

656pureFoldl' :: Stream Identity Int -> Int

657pureFoldl' = runIdentity . S.foldl' (+) 0

658

659{-# INLINE foldableFoldl' #-}

660foldableFoldl' :: Stream Identity Int -> Int

661foldableFoldl' = F.foldl' (+) 0

662

663{-# INLINE foldableSum #-}

664foldableSum :: Stream Identity Int -> Int

665foldableSum = P.sum

666

667{-# INLINE traversableMapM #-}

668traversableMapM :: Stream Identity Int -> IO (Stream Identity Int)

669traversableMapM = P.mapM return