Modulelinear-base-0.8.1

Streaming.Linear

2 types
34 values

Packagelinear-base-0.8.1
Exports36
LicenceMIT

valuechunksOf

:: (HasCallStack, Monad m, Functor f)
=> Int
-> Stream f m r
-> Stream (Stream f m) m r

valueconcats

:: (Monad m, Functor f)
=> Stream (Stream f m) m r
-> Stream f m r

valuedecompose

:: (Monad m, Functor f)
=> Stream (Compose m f) m r
-> Stream f m r

valuedelays :: Applicative f => Double -> Stream f IO r

valuedestroy

:: (Functor f, Monad m)
=> Stream f m r
-> f b %1 -> b
-> m b %1 -> b
-> r %1 -> b
-> b

valueeffect :: (Monad m, Functor f) => m (Stream f m r) %1 -> Stream f m r

valueexpand

:: (Monad m, Functor f)
=> forall a b. (g a %1 -> b) -> f a %1 -> h b
-> Stream f m r
-> Stream g (Stream h m) r

valueexpandPost

:: (Monad m, Functor g)
=> forall a b. (g a %1 -> b) -> f a %1 -> h b
-> Stream f m r
-> Stream g (Stream h m) r

valuegroups

:: (Monad m, Functor f, Functor g)
=> Stream (Sum f g) m r
-> Stream (Sum (Stream f m) (Stream g m)) m r

valuehoistUnexposed

:: (Monad m, Functor f)
=> forall a. m a %1 -> n a
-> Stream f m r
-> Stream f n r

valueinspect :: Monad m => Stream f m r %1 -> m (Either r (f (Stream f m r)))

valueintercalates

:: (Monad m, Monad (t m), MonadTrans t, Consumable x)
=> t m x
-> Stream (t m) m r
-> t m r

valueiterT

:: (Functor f, Monad m)
=> f (m a) %1 -> m a
-> Stream f m a
-> m a

valueiterTM

:: (Functor f, Monad m, MonadTrans t, Monad (t m))
=> f (t m a) %1 -> t m a
-> Stream f m a
-> t m a

valuemapped

:: (Monad m, Functor f)
=> forall x. f x %1 -> m (g x)
-> Stream f m r
-> Stream g m r

valuemappedPost

:: (Monad m, Functor g)
=> forall x. f x %1 -> m (g x)
-> Stream f m r
-> Stream g m r

valuemaps

:: (Monad m, Functor f)
=> forall x. f x %1 -> g x
-> Stream f m r
-> Stream g m r

valuemapsM

:: (Monad m, Functor f)
=> forall x. f x %1 -> m (g x)
-> Stream f m r
-> Stream g m r

valuemapsMPost

:: (Monad m, Functor g)
=> forall x. f x %1 -> m (g x)
-> Stream f m r
-> Stream g m r

valuemapsM_

:: (Functor f, Monad m)
=> forall x. f x %1 -> m x
-> Stream f m r
-> m r

valuemapsPost

:: (Monad m, Functor g)
=> forall x. f x %1 -> g x
-> Stream f m r
-> Stream g m r

valuereplicates

:: (HasCallStack, Monad m, Functor f)
=> Int
-> f ()
-> Stream f m ()

valuereplicatesM :: (Monad m, Functor f) => Int -> m (f ()) -> Stream f m ()

valuerun :: Monad m => Stream m m r %1 -> m r

valueseparate

:: (Monad m, Functor f, Functor g)
=> Stream (Sum f g) m r
-> Stream f (Stream g m) r

valuesplitsAt

:: (HasCallStack, Monad m, Functor f)
=> Int
-> Stream f m r
-> Stream f m (Stream f m r)

valuestreamBuild

:: forall b. (r %1 -> b) -> (m b %1 -> b) -> (f b %1 -> b) -> b
-> Stream f m r

valuestreamFold

:: (Functor f, Monad m)
=> r %1 -> b
-> m b %1 -> b
-> f b %1 -> b
-> Stream f m r
-> b

valueunfold

:: (Monad m, Functor f)
=> s %1 -> m (Either r (f s))
-> s
-> Stream f m r

valueunseparate

:: (Monad m, Functor f, Functor g)
=> Stream f (Stream g m) r
-> Stream (Sum f g) m r

valueuntilJust :: (Monad m, Applicative f) => m (Maybe r) -> Stream f m r

valueunzips

:: (Monad m, Functor f, Functor g)
=> Stream (Compose f g) m r
-> Stream f (Stream g m) r

valuewrap :: (Monad m, Functor f) => f (Stream f m r) %1 -> Stream f m r

valueyields :: (Monad m, Functor f) => f r %1 -> Stream f m r

datadata Of a b where

Constructors

(:>) :: !a -> b -> Of a binfixr 5

Instances2Functor

Functor (Of a)Defined in linear-base-0.8.1 · Streaming.Linear.Internal.Type
Functor (Of a)Defined in linear-base-0.8.1 · Streaming.Linear.Internal.Type

datadata Stream (f :: Type -> Type) (m :: Type -> Type) r where

Constructors

Step :: !f (Stream f m r) -> Stream f m r
Effect :: m (Stream f m r) -> Stream f m r
Return :: r -> Stream f m r

Instances6MonadTrans, Monad, Functor, Applicative

Functor f => MonadTrans (Stream f)Defined in linear-base-0.8.1 · Streaming.Linear.Internal.Type
(Functor m, Functor f) => Applicative (Stream f m)Defined in linear-base-0.8.1 · Streaming.Linear.Internal.Type
(Functor m, Functor f) => Functor (Stream f m)Defined in linear-base-0.8.1 · Streaming.Linear.Internal.Type
(Functor m, Functor f) => Monad (Stream f m)Defined in linear-base-0.8.1 · Streaming.Linear.Internal.Type
(Functor m, Functor f) => Functor (Stream f m)Defined in linear-base-0.8.1 · Streaming.Linear.Internal.Type
(Functor m, Functor f) => Applicative (Stream f m)Defined in linear-base-0.8.1 · Streaming.Linear.Internal.Type