TyTTP.Core.Stream

Definitions

record Subscriber : (Type -> Type) -> Type -> Type -> Type

Totality: total
Visibility: public export
Constructor: 

MkSubscriber : (a -> m ()) -> (() -> m ()) -> (e -> m ()) -> Subscriber m e a

Projections:

.onFailed : Subscriber m e a -> e -> m ()

.onNext : Subscriber m e a -> a -> m ()

.onSucceded : Subscriber m e a -> () -> m ()

Hint: 

Contravariant (Subscriber m e)

.onNext : Subscriber m e a -> a -> m ()

Visibility: public export

onNext : Subscriber m e a -> a -> m ()

Visibility: public export

.onSucceded : Subscriber m e a -> () -> m ()

Visibility: public export

onSucceded : Subscriber m e a -> () -> m ()

Visibility: public export

.onFailed : Subscriber m e a -> e -> m ()

Visibility: public export

onFailed : Subscriber m e a -> e -> m ()

Visibility: public export

record Publisher : (Type -> Type) -> Type -> Type -> Type

Totality: total
Visibility: public export
Constructor: 

MkPublisher : (Subscriber m e a -> m ()) -> Publisher m e a

Projection: 

.subscribe : Publisher m e a -> Subscriber m e a -> m ()

Hint: 

Functor (Publisher m e)

.subscribe : Publisher m e a -> Subscriber m e a -> m ()

Visibility: public export

subscribe : Publisher m e a -> Subscriber m e a -> m ()

Visibility: public export

empty : Publisher m e a

Visibility: export

fail : e -> Publisher m e a

Visibility: export

singleton : Monad m => a -> Publisher m e a

Visibility: export

fromList : Monad m => List a -> Publisher m e a

Visibility: export