zeromq-haskell-0.1: test/display.hs

import Control.Monad
import System.IO
import System.Exit
import System.Environment
import qualified System.ZMQ as ZMQ
import qualified Data.ByteString as SB

main :: IO ()
main = do
    args <- getArgs
    when (length args /= 1) $ do
        hPutStrLn stderr "usage: display <address>"
        exitFailure
    let addr = head args
    c <- ZMQ.init 1 1 False
    s <- ZMQ.socket c ZMQ.Sub
    ZMQ.subscribe s ""
    ZMQ.connect s addr
    forever $ do
        line <- ZMQ.receive s []
        SB.putStrLn line
        hFlush stdout