feat: fix bugs

Author: amirhnajafiz

README.md

@@ -21,25 +21,33 @@ pip install stallion-python-sdk
 ### Client
 Create a client:
 ```python
-from stallion_python_sdk import Client
+# importing Client module
+from stallion import Client
 
+# creating a client
+# with given stallion server url
 c = Client(url="localhost:9090")
 ```
 
 ### Publish
 ```python
+# publish an object on a topic
 c.Publish("book", {'author': "Amirhossein", 'name': "Stallion"})
 ```
 
 ### Subscribe
 ```python
+# creating a handler
+# any published object will be given to this handler as data
 def handler(data):
-    print(data)
+    print(f'{data['author']}: {data['name']})
 
+# subscribe over a topic with given handler
 c.Subscribe("book", handler)
 ```
 
 ### Unsubscribe
 ```python
+# unsubscribe from a topic
 c.Unsubscribe("book")
 ```

setup.cfg

@@ -1,11 +1,12 @@
 [metadata]
 name = stallion-python-sdk
-version = 1.2.1
+version = 1.2.2
 author = amirhnajafiz
 author_email = najafizadeh21@gmail.com
 description = SDK for Stallion message broker
 long_description= file: README.md
 long_description_content_type = text/markdown
+url = https://github.com/amirhnajafiz/stallion-python-sdk
 classifiers =
     Programming Language :: Python :: 3
     License :: OSI Approved :: MIT License

src/stallion/client.py

@@ -1,4 +1,5 @@
 import threading
+from time import sleep
 
 from parser import *
 from network import Network
@@ -57,16 +58,22 @@ def __read_data_from_server__(self):
     def Publish(self, topic, data):
         self.__net.write(jsonEncode(newMessage(topic=topic, data=data)))
 
+        sleep(0.001)
+
     """
     Subscribe over a topic.
     """
     def Subscribe(self, topic, handler):
         self.__handlers[topic] = handler
         self.__net.write(jsonEncode(newMessage(type=2, topic=topic)))
+        
+        sleep(0.001)
 
     """
     Unsubscribe from a topic.
     """
     def Unsubscribe(self, topic):
         self.__handlers.pop(topic)
         self.__net.write(jsonEncode(newMessage(type=3, topic=topic)))
+
+        sleep(0.001)

tests/test.py

@@ -1,4 +1,3 @@
-from time import sleep
 from stallion.client import Client
 
 
@@ -14,13 +13,9 @@ def handler(data):
     # create client
     c = Client(url="localhost:9090")
 
-    sleep(1)
-
     # subscribe over a topic
     c.Subscribe("book", handler)
 
-    sleep(1)
-
     # publish messages over a topic
     c.Publish("book", {'author': "Amirhossein", 'name': "Stallion"})