Network.Mom.Patterns.Basic.Pusher

Pusher side of 'Pipeline'

Documentation

data Pusher

The pusher data type

withPusher :: Context -> String -> LinkType -> (Pusher -> IO a) -> IO a

The function in whose scope the pusher lives:

• Context - The zeromq Context
• String - The address
• LinkType - Link type; usually, you want to bind a pusher to its address
• (Pusher -> IO a) - Action in whose scope the pusher lives

push :: Pusher -> Source -> IO ()

Push a job down the pipeline; the Source creates the outgoing stream.