c5cb2d8 · streamly · git.iko.soy

git.iko.soy/streamly

on master help sign in

Expose fromCallback

c5cb2d8Harendra Kumar4 years ago

src/Streamly/Data/Stream/Concurrent.hs+1

@@ -133,6 +133,7 @@ module Streamly.Data.Stream.Concurrent

133 -- | Uses a concurrency channel to evaluate multiple actions concurrently.

134 , parRepeatM

135 , parReplicateM

136+ , fromCallback

136

137

137 -- *** Map

138 -- *** Map

138 -- | Uses a concurrency channel to evaluate multiple mapped actions

139 -- | Uses a concurrency channel to evaluate multiple mapped actions

src/Streamly/Internal/Data/Stream/Concurrent.hs+3−3

@@ -812,9 +812,9 @@ newCallbackStream = do

812 -- XXX Use fromChannelD?

813 return (callback, fromChannel chan)

814

815−-- | Takes a callback setter function and provides it with a callback. The

815+-- | Supplies a stream generating callback to a callback setter function. Each

816−-- callback when invoked adds a value at the tail of the stream. Returns a

816+-- invocation of the callback results in a value being generated in the

817−-- stream of values generated by the callback.

817+-- resulting stream.

818--

819-- /Pre-release/

820--