* Removed sync waiting from downlink models.

* Added cookbook example for join map lane.

Author: DobromirM

examples/cookbook/join_map_lane.py

@@ -0,0 +1,77 @@
+#  Copyright 2015-2020 SWIM.AI inc.
+#
+#  Licensed under the Apache License, Version 2.0 (the "License");
+#  you may not use this file except in compliance with the License.
+#  You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+#  Unless required by applicable law or agreed to in writing, software
+#  distributed under the License is distributed on an "AS IS" BASIS,
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#  See the License for the specific language governing permissions and
+#  limitations under the License.
+#
+#  Licensed under the Apache License, Version 2.0 (the "License");
+#  you may not use this file except in compliance with the License.
+#  You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+#  Unless required by applicable law or agreed to in writing, software
+#  distributed under the License is distributed on an "AS IS" BASIS,
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#  See the License for the specific language governing permissions and
+#  limitations under the License.
+#
+#  Licensed under the Apache License, Version 2.0 (the "License");
+#  you may not use this file except in compliance with the License.
+#  You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+#  Unless required by applicable law or agreed to in writing, software
+#  distributed under the License is distributed on an "AS IS" BASIS,
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#  See the License for the specific language governing permissions and
+#  limitations under the License.
+#
+#  Licensed under the Apache License, Version 2.0 (the "License");
+#  you may not use this file except in compliance with the License.
+#  You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+#  Unless required by applicable law or agreed to in writing, software
+#  distributed under the License is distributed on an "AS IS" BASIS,
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+#  See the License for the specific language governing permissions and
+#  limitations under the License.
+import time
+from swimai import SwimClient
+
+THRESHOLD = 1000
+
+
+async def custom_did_update(key, new_value, old_value):
+    if new_value > THRESHOLD:
+        print(f'{key} has {new_value} residents')
+
+
+if __name__ == '__main__':
+    with SwimClient() as swim_client:
+        host_uri = 'warp://localhost:53556'
+        node_uri = '/join/state/all'
+        lane_uri = 'join'
+
+        map_downlink = swim_client.downlink_map()
+        map_downlink.set_host_uri(host_uri)
+        map_downlink.set_node_uri(node_uri)
+        map_downlink.set_lane_uri(lane_uri)
+        map_downlink.did_update(custom_did_update)
+        map_downlink.open()
+
+        time.sleep(2)
+
+        print('Stopping the client in 2 seconds')
+        time.sleep(2)

swimai/client/_downlinks/_downlinks.py

@@ -378,11 +378,10 @@ async def _send_message(self, message: '_Envelope') -> None:
 
     async def _get_value(self) -> Any:
         """
-        Get the value of the downlink after it has been synced.
+        Get the value of the downlink.
 
         :return:                - The current value of the downlink.
         """
-        await self._synced.wait()
         return self._value
 
     async def __set_value(self, message: '_Envelope') -> None:
@@ -529,7 +528,6 @@ async def _get_value(self, key) -> Any:
         :param key              - The key of the entry.
         :return:                - The current value of the downlink.
         """
-        await self._synced.wait()
         return self._map.get(key, (Value.absent(), Value.absent()))[1]
 
     async def _get_values(self) -> list:
@@ -538,7 +536,6 @@ async def _get_values(self) -> list:
 
         :return:                - A list with all the values from the downlink map.
         """
-        await self._synced.wait()
         return list(self._map.values())
 
     async def __receive_update(self, message: '_Envelope') -> None: