Commit fa308984 authored by Mart Lubbers's avatar Mart Lubbers
Browse files

make up to date with the latest greatest iTask master

parent bccc6e9d
Pipeline #56899 passed with stages
in 3 minutes and 41 seconds
...@@ -127,15 +127,15 @@ connectionsHandlers = ...@@ -127,15 +127,15 @@ connectionsHandlers =
, onData = onData , onData = onData
, onShareChange = onShareChange , onShareChange = onShareChange
, onTick = \_ _ w. (Ok (), ?None, [], False, w) , onTick = \_ _ w. (Ok (), ?None, [], False, w)
, onDisconnect = \_ _ w. (Ok (), ?None, w) , onDisconnect = \_ _ _ w. (Ok (), ?None, w)
, onDestroy = \_ w. (Ok (), [], w) , onDestroy = \_ w. (Ok (), [], w)
} }
onData :: !String () MQTTClient *IWorld -> *(MaybeErrorString (), ?MQTTClient, [String], Bool, *IWorld) onData :: !ConnectionId !String () MQTTClient *IWorld -> *(MaybeErrorString (), ?MQTTClient, [String], Bool, *IWorld)
onData _ _ client iworld onData _ _ _ client iworld
# (ret, iworld) = processCall client.context iworld # (ret, iworld) = processCall client.context iworld
| ret == 0 = let (c,w) = receive client iworld in (Ok (), ?Just c, [], False, w) | ret == 0 = let (c,w) = receive client iworld in (Ok (), ?Just c, [], False, w)
| otherwise = (Error $ "Mqtt process failed: " +++ errorCodeToString ret, ?None, [], False, iworld) | otherwise = (Error $ "Mqtt process failed: " +++ errorCodeToString ret, ?None, [], False, iworld)
onShareChange :: !() MQTTClient *IWorld -> *(MaybeErrorString (), ?MQTTClient, [String], Bool, *IWorld) onShareChange :: !() MQTTClient *IWorld -> *(MaybeErrorString (), ?MQTTClient, [String], Bool, *IWorld)
onShareChange _ c=:{subscribe=[(topic, qos):tt]} w=:{IWorld|clock} onShareChange _ c=:{subscribe=[(topic, qos):tt]} w=:{IWorld|clock}
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment