@@ -1008,23 +1008,6 @@ concatSmapMWith
1008concatSmapMWith combine f initial =
1008concatSmapMWith combine f initial =
1009 IsStream.concatMapWith combine id . smapM f initial
1009 IsStream.concatMapWith combine id . smapM f initial
1011−-- Keep concating either streams as long as rights are generated, stop as soon
1012−-- as a left is generated and concat the left stream.
1014−-- See also: 'handle'
1020− :: -- (IsStream t, MonadAsync m) =>
1021− (forall x. t m x -> t m x -> t m x)
1022− -> (a -> t m (Either (t m b) b))
1025−concatMapEitherWith = undefined
1028-- XXX Implement a StreamD version for fusion.
1011-- XXX Implement a StreamD version for fusion.
1030-- | Combine streams in pairs using a binary stream combinator, then combine
1013-- | Combine streams in pairs using a binary stream combinator, then combine
@@ -1141,9 +1124,26 @@ iterateSmapMWith combine f initial stream =
1141 (fromEffect $ f b a)
1124 (fromEffect $ f b a)
1143------------------------------------------------------------------------------
1126------------------------------------------------------------------------------
1144−-- iterateMap - Either streams
1127+-- Either streams
1145------------------------------------------------------------------------------
1128------------------------------------------------------------------------------
1130+-- Keep concating either streams as long as rights are generated, stop as soon
1131+-- as a left is generated and concat the left stream.
1133+-- See also: 'handle'
1139+ :: -- (IsStream t, MonadAsync m) =>
1140+ (forall x. t m x -> t m x -> t m x)
1141+ -> (a -> t m (Either (t m b) b))
1144+concatMapEitherWith = undefined
1147-- | In an 'Either' stream iterate on 'Left's. This is a special case of
1147-- | In an 'Either' stream iterate on 'Left's. This is a special case of
1148-- 'iterateMapWith':
1148-- 'iterateMapWith':