X-Git-Url: https://git.martlubbers.net/?a=blobdiff_plain;f=miTask.icl;h=f8fa8bae4785cae9628977b3617d402a509b0229;hb=4dff4046c87727f8b09558969f7c655b9e4de3c1;hp=84b25633289174f4a0fa15d88c6ef9d3d2ee4b32;hpb=c667554eb5dc359481a5f84b60649169f31e0f3d;p=mTask.git diff --git a/miTask.icl b/miTask.icl index 84b2563..f8fa8ba 100644 --- a/miTask.icl +++ b/miTask.icl @@ -7,13 +7,39 @@ from Text import class Text(concat,join,split), instance Text String import iTasks import mTask +derive class iTask MTaskMessage + Start :: *World -> *World -Start world = startEngine mTaskTask world +Start world = startEngine (withShared ([], False, [], False) mTaskTask) world +//Start world = startEngine mTaskTask world + +mTaskTask :: (Shared ([MTaskMessage],Bool,[MTaskMessage],Bool)) -> Task () +mTaskTask ch = + syncNetworkChannel "localhost" 8124 "\n" decode encode ch ||- + ( + sendMsg (hd msgs) ch >>= \_-> + sendMsg (hd (tl msgs)) ch >>= \_-> + viewSharedInformation "channels" [ViewWith lens] ch @! () + ) + where + lens :: ([MTaskMessage],Bool,[MTaskMessage],Bool) -> ([String], [String]) + lens (r,_,s,_) = (map toString r, map toString s) + + msgs = toMessages 500 (toRealByteCode (unMain bc)) + + bc :: Main (ByteCode Int Expr) + bc = sds \x=0 In {main = x =. x +. lit 1} + +makemTask :: Int (Main (ByteCode a Expr)) -> String +makemTask to bc +# (bc, st) = toRealByteCode (unMain bc) += "t" +++ toString (toChar (to / 265)) + +++ toString (toChar (to rem 265)) +++ toString bc +++ "\n" -mTaskTask :: Task () -mTaskTask = withShared ([],False,[],False) (\ch-> - syncNetworkChannel "localhost" 8123 "\n" id id ch ||- - updateSharedInformation "channels" [] ch @! ()) +sendMsg :: MTaskMessage (Shared ([MTaskMessage],Bool,[MTaskMessage],Bool)) -> Task () +sendMsg m ch +| not (trace_tn ("\'" +++ toString m +++ "\'")) = undef += upd (\(r,rs,s,ss)->(r,rs,s ++ [m],ss)) ch @! () syncNetworkChannel :: String Int String (String -> m) (m -> String) (Shared ([m],Bool,[m],Bool)) -> Task () | iTask m syncNetworkChannel server port msgSeparator decodeFun encodeFun channel