Add asynchronous invocation to Service and MultiServiceClient.

socketless/messenger.pxd

@@ -3,6 +3,7 @@
 from channel cimport Channel
 
 cpdef invoke_all(message, messengers)
+cpdef send_all(message, messengers, collector)
 
 cdef class Collector:
     cdef unsigned int item_count

socketless/messenger.pyx

@@ -12,6 +12,10 @@ import logging
 from channel cimport Channel
 from channel import Channel, DisconnectedException
 
+cpdef send_all(message, messengers, collector):
+    for token, messenger in messengers:
+        (<Messenger>messenger).send(message, token, collector)
+
 cpdef invoke_all(message, messengers):
     cdef object messenger
     cdef object token
@@ -150,12 +154,9 @@ cdef class Messenger:
             callback(None, token)
 
     cpdef close(self):
-        self.connector.kill()
-        if self.connected:
-            try:
-                self.channel.close()
-            except DisconnectedException:
-                pass
+        if self.connector:
+            self.connector.kill()
+            self.connector = None
         self._teardown()
 
     def __repr__(self):

socketless/serialize.pxd

@@ -4,6 +4,7 @@ cdef class MessageReader(object):
     cdef object message
     cdef public unsigned long i
 
+    cpdef update(self, object message)
     cdef inline object _read(self, unsigned long length)
     cdef inline object _read_string(self)
     cdef inline unsigned long read_int(self)

socketless/serialize.pyx

@@ -12,7 +12,10 @@ cdef object int64_unpack = struct.Struct('!Q').unpack
 
 cdef class MessageReader:
     """docstring for MessageReader"""
-    def __init__(self, message):
+    def __init__(self, message=None):
+        self.update(message)
+
+    cpdef update(self, message):
         self.message = message
         self.i = 0