Winning the 0MQ book at #RealtimeConfEu

zmqchat.hs

{-# LANGUAGE OverloadedStrings #-}
module Main where

import Control.Monad
import System.IO
import System.ZMQ3.Monadic
import qualified Data.ByteString.Char8 as CS
import Control.Concurrent (forkIO)

main :: IO ()
main = do
  void $ forkIO $ runZMQ listener
  runZMQ input
      
listener =
  do sub <- socket Sub
     subscribe sub ""
     forM_ [1..254::Int] $ \i ->
         connect sub $ "tcp://192.168.69." ++ show i ++ ":9000"
     forever $
             do receive sub >>= liftIO . CS.putStrLn
                liftIO $ hFlush stdout
       
       
input =
  do pub <- socket Pub
     bind pub "tcp://*:9000"
     forever $
       liftIO CS.getLine >>= send pub [] . ("astro: " `CS.append`)