X-Git-Url: https://git.martlubbers.net/?a=blobdiff_plain;f=miTask.icl;h=f8fa8bae4785cae9628977b3617d402a509b0229;hb=4dff4046c87727f8b09558969f7c655b9e4de3c1;hp=a00d6f0a6f5b06ca27ccd366304b299b3134695a;hpb=a0182655c28502ffcadbe36de99d9a4e503e310e;p=mTask.git diff --git a/miTask.icl b/miTask.icl index a00d6f0..f8fa8ba 100644 --- a/miTask.icl +++ b/miTask.icl @@ -7,23 +7,39 @@ from Text import class Text(concat,join,split), instance Text String import iTasks import mTask -Start :: *World -> *World -Start world = startEngine mTaskTask world +derive class iTask MTaskMessage -mTaskTask :: Task () -mTaskTask = withShared ([],False,[],False) (\ch-> - syncNetworkChannel "localhost" 8123 "\n" id id ch ||- - sendByteCode ||- - updateSharedInformation "channels" [] ch @! ()) +Start :: *World -> *World +Start world = startEngine (withShared ([], False, [], False) mTaskTask) world +//Start world = startEngine mTaskTask world -sendByteCode :: Task () -sendByteCode = viewInformation "send" [] "4" @! () -// (toReadableByteCode (unMain bc)) @! () +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=41 In - sds \y=1 In - {main = x =. x +. y} + 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" + +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