c5cb2d8 · streamly · git.iko.soy

git.iko.soy/streamly

Expose fromCallback

commitc5cb2d8e3ca139be820bb22bd9fd01ba9b267f56 authorHarendra Kumar <harendra@composewell.com> dateMon 2 Jan 2023, 12:32 (4 years ago) parentb274742

2 files changed+4−3

unifiedsplit

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

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

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

134134 , parRepeatM

135135 , parReplicateM

136+ , fromCallback

136137

137138 -- *** Map

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

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

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

812812 -- XXX Use fromChannelD?

813813 return (callback, fromChannel chan)

814814

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

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

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

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

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

817+-- resulting stream.

818818--

819819-- /Pre-release/

820820--