Module

Pipes.Core

Package
purescript-pipes
Repository
felixSchl/purescript-pipes

#Effect Source

#Producer Source

type Producer b = Proxy X Unit Unit b

#Pipe Source

type Pipe a b = Proxy Unit a Unit b

#Consumer Source

type Consumer a = Proxy Unit a Unit X

#Client Source

type Client a' a = Proxy a' a Unit X

#Server Source

type Server b' b = Proxy X Unit b' b

#Effect_ Source

type Effect_ m r = forall y y' x x'. Proxy x' x y' y m r

#Producer_ Source

type Producer_ b m r = forall x x'. Proxy x' x Unit b m r

#Consumer_ Source

type Consumer_ a m r = forall y y'. Proxy Unit a y' y m r

#Server_ Source

type Server_ b' b m r = forall x x'. Proxy x' x b' b m r

#Client_ Source

type Client_ a' a m r = forall y y'. Proxy a' a y' y m r

#runEffect Source

runEffect :: forall r m. Monad m => Effect m r -> m r

#runEffectRec Source

runEffectRec :: forall r m. MonadRec m => Effect m r -> m r

#respond Source

respond :: forall x' x a' a m. Monad m => a -> Proxy x' x a' a m a'

#(//>) Source

Operator alias for Pipes.Core.composeResponse (left-associative / precedence 4)

#(/>/) Source

Operator alias for Pipes.Core.composeResponse' (right-associative / precedence 4)

#(>\\) Source

Operator alias for Pipes.Core.composeRequest (left-associative / precedence 5)

#(\>\) Source

Operator alias for Pipes.Core.composeRequest' (right-associative / precedence 4)

#(+>>) Source

Operator alias for Pipes.Core.composePull' (right-associative / precedence 6)

#(>+>) Source

Operator alias for Pipes.Core.composePull (left-associative / precedence 7)

#(>>~) Source

Operator alias for Pipes.Core.composePush' (left-associative / precedence 7)

#(>~>) Source

Operator alias for Pipes.Core.composePush (right-associative / precedence 8)

#(\<\) Source

Operator alias for Pipes.Core.flippedComposeResponse' (left-associative / precedence 4)

#(/</) Source

Operator alias for Pipes.Core.flippedComposeRequest' (right-associative / precedence 4)

#(<~<) Source

Operator alias for Pipes.Core.flippedComposePush (left-associative / precedence 8)

#(<+<) Source

Operator alias for Pipes.Core.flippedComposePull (right-associative / precedence 7)

#(<\\) Source

Operator alias for Pipes.Core.flippedComposeResponse (right-associative / precedence 3)

#(//<) Source

Operator alias for Pipes.Core.flippedComposeRequest (left-associative / precedence 4)

#(~<<) Source

Operator alias for Pipes.Core.flippedComposePush' (right-associative / precedence 7)

#(<<+) Source

Operator alias for Pipes.Core.flippedComposePull' (left-associative / precedence 6)

#composeResponse Source

composeResponse :: forall c' c b' b a' x' x m. Monad m => Proxy x' x b' b m a' -> (b -> Proxy x' x c' c m b') -> Proxy x' x c' c m a'

#composeResponse' Source

composeResponse' :: forall c' c b' b a' a x' x m. Monad m => (a -> Proxy x' x b' b m a') -> (b -> Proxy x' x c' c m b') -> (a -> Proxy x' x c' c m a')

#request Source

request :: forall m y' y a' a. Monad m => a' -> Proxy a' a y' y m a

#composeRequest Source

composeRequest :: forall m y' y c b' b a' a. Monad m => (b' -> Proxy a' a y' y m b) -> Proxy b' b y' y m c -> Proxy a' a y' y m c

#composeRequest' Source

composeRequest' :: forall m y' y c' c b' b a' a. Monad m => (b' -> Proxy a' a y' y m b) -> (c' -> Proxy b' b y' y m c) -> (c' -> Proxy a' a y' y m c)

#pull Source

pull :: forall r m a' a. Monad m => a' -> Proxy a' a a' a m r

#composePull Source

composePull :: forall r m _c' c' c b' b a' a. Monad m => (b' -> Proxy a' a b' b m r) -> (_c' -> Proxy b' b c' c m r) -> (_c' -> Proxy a' a c' c m r)

#composePull' Source

composePull' :: forall r m c' c b' b a' a. Monad m => (b' -> Proxy a' a b' b m r) -> Proxy b' b c' c m r -> Proxy a' a c' c m r

#push Source

push :: forall r m a' a. Monad m => a -> Proxy a' a a' a m r

#composePush Source

composePush :: forall r m c' c b' b a' a _a. Monad m => (_a -> Proxy a' a b' b m r) -> (b -> Proxy b' b c' c m r) -> (_a -> Proxy a' a c' c m r)

#composePush' Source

composePush' :: forall r m c' c b' b a' a. Monad m => Proxy a' a b' b m r -> (b -> Proxy b' b c' c m r) -> Proxy a' a c' c m r

#reflect Source

reflect :: forall r m b' b a' a. Monad m => Proxy a' a b' b m r -> Proxy b b' a a' m r

#flippedComposeResponse' Source

flippedComposeResponse' :: forall c' c b' b a' a x' x m. Monad m => (b -> Proxy x' x c' c m b') -> (a -> Proxy x' x b' b m a') -> (a -> Proxy x' x c' c m a')

Equivalent to ('/>/') with the arguments flipped

#flippedComposeRequest' Source

flippedComposeRequest' :: forall m y' y c' c b' b a' a. Monad m => (c' -> Proxy b' b y' y m c) -> (b' -> Proxy a' a y' y m b) -> (c' -> Proxy a' a y' y m c)

Equivalent to ('>') with the arguments flipped

#flippedComposePush Source

flippedComposePush :: forall r m c' c b' b a' a. Monad m => (b -> Proxy b' b c' c m r) -> (a -> Proxy a' a b' b m r) -> (a -> Proxy a' a c' c m r)

Equivalent to ('>~>') with the arguments flipped

#flippedComposePull Source

flippedComposePull :: forall r m c' c b' b a' a. Monad m => (c' -> Proxy b' b c' c m r) -> (b' -> Proxy a' a b' b m r) -> (c' -> Proxy a' a c' c m r)

Equivalent to ('>+>') with the arguments flipped

#flippedComposeResponse Source

flippedComposeResponse :: forall c' c b' b a' x' x m. Monad m => (b -> Proxy x' x c' c m b') -> Proxy x' x b' b m a' -> Proxy x' x c' c m a'

Equivalent to ('//>') with the arguments flipped

#flippedComposeRequest Source

flippedComposeRequest :: forall m y' y c b' b a' a. Monad m => Proxy b' b y' y m c -> (b' -> Proxy a' a y' y m b) -> Proxy a' a y' y m c

Equivalent to ('>\') with the arguments flipped

#flippedComposePush' Source

flippedComposePush' :: forall r m c' c b' b a' a. Monad m => (b -> Proxy b' b c' c m r) -> Proxy a' a b' b m r -> Proxy a' a c' c m r

Equivalent to ('>>~') with the arguments flipped

#flippedComposePull' Source

flippedComposePull' :: forall r m c' c b' b a' a. Monad m => Proxy b' b c' c m r -> (b' -> Proxy a' a b' b m r) -> Proxy a' a c' c m r

Equivalent to ('+>>') with the arguments flipped

Re-exports from Pipes.Internal

#X Source

newtype X

#Proxy Source

data Proxy a' a b' b m r

Instances

#closed Source

closed :: forall a. X -> a