tcp/test.icl

   1 module test
   2
   3 import iTasks
   4 import StdMisc,StdDebug
   5 import Data.Maybe
   6
   7 Start w = startEngine t w
   8
   9 t = withShared () \channels->
  10         forever (chooseAction [(Action "Set", ())] >>- \_->set () channels)
  11         ||- tcpconnect "localhost" 8123 channels
  12                 {ConnectionHandlers|
  13                         onConnect=onConnect,
  14                         onData=onData,
  15                         onShareChange=onShareChange,
  16                         onDisconnect=onDisconnect}
  17         where
  18                 onConnect acc ()
  19                         | not (trace_tn "onConnect") = undef
  20                         = (Ok "", Nothing, [], False)
  21
  22                 onData newdata acc ()
  23                         | not (trace_tn "onData") = undef
  24                         = (Ok "", Nothing, [], False)
  25
  26                 onShareChange acc ()
  27                         | not (trace_tn "onShareChange") = undef
  28                         = (Ok "", Nothing, [], False)
  29
  30                 onDisconnect _ ()
  31                         | not (trace_tn "onDisconnect") = undef
  32                         = (Ok "", Nothing)