repeat package:streamly-core

Generate an infinite stream by repeating a pure value.

>>> repeat x = Stream.repeatM (pure x)

Generate an infinite stream by repeating a pure value. Pre-release

>>> repeatM = Stream.sequence . Stream.repeat

Generate a stream by repeatedly executing a monadic action forever.

>>> :{
repeatAction =
Stream.repeatM (threadDelay 1000000 >> print 1)
& Stream.take 10
& Stream.fold Fold.drain
:}

Generates an infinite stream repeating the seed.

Emit only repeated elements, once. Unimplemented

Emit only repeated elements, once. Unimplemented

>>> repeatM = StreamK.sequence . StreamK.repeat

>>> repeatM = fix . StreamK.consM

>>> repeatM = cycle1 . StreamK.fromEffect

Generate a stream by repeatedly executing a monadic action forever.

>>> :{
repeatAction =
StreamK.repeatM (threadDelay 1000000 >> print 1)
& StreamK.take 10
& StreamK.fold Fold.drain
:}

Like repeatM but takes a stream cons operation to combine the actions in a stream specific manner. A serial cons would repeat the values serially while an async cons would repeat concurrently. Pre-release