@@ -47,7 +47,7 @@ import Control.Monad.IO.Class (MonadIO(..))
47import Control.Monad.Reader.Class (MonadReader(..))
47import Control.Monad.Reader.Class (MonadReader(..))
48import Control.Monad.State.Class (MonadState(..))
48import Control.Monad.State.Class (MonadState(..))
49import Control.Monad.Trans.Class (MonadTrans)
49import Control.Monad.Trans.Class (MonadTrans)
50−import Data.Semigroup (Semigroup(..), cycle1)
50+import Data.Semigroup (Semigroup(..))
51import Prelude hiding (drop, take, zipWith)
51import Prelude hiding (drop, take, zipWith)
52import Asyncly.Core
52import Asyncly.Core
53import Asyncly.Prelude
53import Asyncly.Prelude
@@ -515,7 +515,7 @@ instance Monad m => Functor (ZipStream m) where
515 in m Nothing stp yield
515 in m Nothing stp yield
517instance Monad m => Applicative (ZipStream m) where
517instance Monad m => Applicative (ZipStream m) where
518− pure a = ZipStream $ cycle1 (pure a)
518+ pure = ZipStream . yielding
519 (<*>) = zipWith id
519 (<*>) = zipWith id
521instance Streaming ZipStream where
521instance Streaming ZipStream where
@@ -581,7 +581,7 @@ instance Monad m => Functor (ZipAsync m) where
581 in m Nothing stp yield
581 in m Nothing stp yield
583instance MonadAsync m => Applicative (ZipAsync m) where
583instance MonadAsync m => Applicative (ZipAsync m) where
584− pure a = ZipAsync $ cycle1 (pure a)
584+ pure = ZipAsync . yielding
585 (<*>) = zipAsyncWith id
585 (<*>) = zipAsyncWith id
587instance Streaming ZipAsync where
587instance Streaming ZipAsync where