repeat package:streamly

repeat :: (IsStream t, Monad m) => a -> t m a

Generate an infinite stream by repeating a pure value.

repeat :: IsStream t => a -> t m a

repeat :: Monad m => a -> SerialT m a

Generate an infinite stream by repeating a pure value.

>>> repeatM = fix . consM

>>> repeatM = cycle1 . fromEffect

Generate a stream by repeatedly executing a monadic action forever.

>>> :{
repeatAsync =
Stream.repeatM (threadDelay 1000000 >> print 1)
& Stream.take 10
& Stream.fromAsync
& Stream.drain
:}

Concurrent, infinite (do not use with fromParallel)

Emit only repeated elements, once. Unimplemented

Definition:

>>> parRepeatM cfg = Stream.parSequence cfg . Stream.repeat

Generate a stream by repeatedly executing a monadic action forever.