Changeset 9 for tabled.py

Timestamp:

02/03/08 10:09:51 (4 years ago)

Author:

mike

Message:

Added deferreds

Files:

• tabled.py (modified) (3 diffs)

tabled.py

@@ -11 +11 @@
 from twisted.internet import reactor
 from twisted.protocols.basic import NetstringReceiver
+from twisted.internet import defer
 
 tables = {"test_table":holdemtable()}
@@ -18 +19 @@
         self.table = None
         self.id = None
+
+    def sendMessage(self, data):
+        self.transport.write( cjson.encode(
+            data) )
+        d = defer.Deferred()
+        d.addCallback(self.sendMessage)
+        self.table.addDeferred(self.id, d)
+
 
     def dataReceived(self, data):
@@ -41 +50 @@
                 else:
                     self.id = self.table.addPlayer(decoded)
+                    d = defer.Deferred()
+                    d.addCallback(self.sendMessage)
+                    self.table.addDeferred(self.id, d)
             else:
                 self.transport.write( cjson.encode(protocol.MakeError(102,"Unknown Method")) )