{- Replicated input -} 

new x : ^Int

run (
  x!1 | x!2 | x!3     {- Three parallel output processes -}
| x?* arg = printi! arg   {- An input process - a server -}
)


{- Timeouts -}

val t = 1   {- seconds -}

run 
(
  x!4 | x!5 | x!6     {- Three parallel output processes -}
| wait 
    x?* arg = printi! arg 
  timeout 
    t -> print! "Timeout!" 
)