Modulelinear-base-0.8.1

Streaming.Linear

Synopsis

value chunksOf
value concats
value decompose
value delays
value destroy
value effect
value expand
value expandPost
value groups
value hoistUnexposed
value inspect
value intercalates
value iterT
value iterTM
value mapped
value mappedPost
value maps
value mapsM
value mapsMPost
value mapsM_
value mapsPost
value replicates
value replicatesM
value run
value separate
value splitsAt
value streamBuild
value streamFold
value unfold
value unseparate
value untilJust
value unzips
value wrap
value yields
data Of
data Stream

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