1. Lynn Rees
  2. wire

Commits

Lynn Rees  committed a265891

- use that attribute

  • Participants
  • Parent commits 3adc9e7
  • Branches pu

Comments (0)

Files changed (19)

File wire/talk/bencodew.py

View file
     def bencode(self):
         '''bencode serialization'''
         with self._sync as sync:
-            sync(bencode(d) for d in sync.iterable)
+            sync(bencode(d.data) for d in sync.iterable)
         return self
 
 
     def bencode(self):
         '''bencode serialization'''
         with self._sync as sync:
-            sync(bdecode(d) for d in sync.iterable)
+            sync(bdecode(d.data) for d in sync.iterable)
         return self

File wire/talk/bsonw.py

View file
     def bson(self):
         '''bson serialization'''
         with self._sync as sync:
-            sync(dumps(d) for d in sync.iterable)
+            sync(dumps(d.data) for d in sync.iterable)
         return self
 
 
     def bson(self):
         '''bson serialization'''
         with self._sync as sync:
-            sync(loads(d) for d in sync.iterable)
+            sync(loads(d.data) for d in sync.iterable)
         return self

File wire/talk/csvw.py

View file
         '''csv serialization'''
         dump = self.dumps
         with self._sync as sync:
-            sync(dump(d, **kw) for d in sync.iterable)
+            sync(dump(d.data, **kw) for d in sync.iterable)
         return self
 
 
         kw = self._kw
         loads = self.loads
         with self._sync as sync:
-            sync(loads(d, **kw) for d in sync.iterable)
+            sync(loads(d.data, **kw) for d in sync.iterable)
         return self

File wire/talk/excelw.py

View file
         '''excel serialization'''
         dump = self.dumps
         with self._sync as sync:
-            sync(dump(d, **kw) for d in sync.iterable)
+            sync(dump(d.data, **kw) for d in sync.iterable)
         return self
 
 
         kw = self._kw
         loads = self.loads
         with self._sync as sync:
-            sync(loads(d, **kw) for d in sync.iterable)
+            sync(loads(d.data, **kw) for d in sync.iterable)
         return self

File wire/talk/htmlw.py

View file
     def html(self, **kw):
         '''html serialization'''
         with self._sync as sync:
-            sync(tostring(d, **kw) for d in sync.iterable)
+            sync(tostring(d.data, **kw) for d in sync.iterable)
         return self
 
 
     def html(self, **kw):
         '''html serialization'''
         with self._sync as sync:
-            sync(fromstring(d, **kw) for d in sync.iterable)
+            sync(fromstring(d.data, **kw) for d in sync.iterable)
         return self

File wire/talk/jsonw.py

View file
         '''JSON serialization'''
         dump = dumps
         with self._sync as sync:
-            sync(dump(d, use_decimal=True, **kw) for d in sync.iterable)
+            sync(dump(d.data, use_decimal=True, **kw) for d in sync.iterable)
         return self
 
 
         '''JSON serialization'''
         load = loads
         with self._sync as sync:
-            sync(load(d, use_decimal=True, **kw) for d in sync.iterable)
+            sync(load(d.data, use_decimal=True, **kw) for d in sync.iterable)
         return self

File wire/talk/marshalw.py

View file
         '''marshal serialization'''
         dump = dumps
         with self._sync as sync:
-            sync(dump(d) for d in sync.iterable)
+            sync(dump(d.data) for d in sync.iterable)
         return self
 
 
         '''marshal serialization'''
         load = loads
         with self._sync as sync:
-            sync(load(d) for d in sync.iterable)
+            sync(load(d.data) for d in sync.iterable)
         return self

File wire/talk/msgpackw.py

View file
         '''MessagePack serialization'''
         dump = msgpack.packb
         with self._sync as sync:
-            sync(dump(d) for d in sync.iterable)
+            sync(dump(d.data) for d in sync.iterable)
         return self
 
 
         '''Message Pack serialization'''
         load = msgpack.unpackb
         with self._sync as sync:
-            sync(load(d) for d in sync.iterable)
+            sync(load(d.data) for d in sync.iterable)
         return self

File wire/talk/multipartw.py

View file
         '''multipart serialization'''
         dump = encode_multipart_formdata
         with self._sync as sync:
-            sync(dump(d) for d in sync.iterable)
+            sync(dump(d.data) for d in sync.iterable)
         return self
 
 
         '''multipart serialization'''
         load = self.loads
         with self._sync as sync:
-            sync(load(d) for d in sync.iterable)
+            sync(load(d.data) for d in sync.iterable)
         return self

File wire/talk/netstringw.py

View file
         '''netstring serialization'''
         dump = encode
         with self._sync as sync:
-            sync(dump(d) for d in sync.iterable)
+            sync(dump(d.data) for d in sync.iterable)
         return self
 
 
         '''netstring serialization'''
         load = decode
         with self._sync as sync:
-            sync(load(d) for d in sync.iterable)
+            sync(load(d.data) for d in sync.iterable)
         return self

File wire/talk/picklew.py

View file
         '''pickle serialization'''
         dump = pickle.dumps
         with self._sync as sync:
-            sync(dump(d, pickle.HIGHEST_PROTOCOL) for d in sync.iterable)
+            sync(dump(d.data, pickle.HIGHEST_PROTOCOL) for d in sync.iterable)
         return self
 
 
         '''pickle serialization'''
         load = pickle.loads
         with self._sync as sync:
-            sync(load(d) for d in sync.iterable)
+            sync(load(d.data) for d in sync.iterable)
         return self

File wire/talk/plistw.py

View file
         '''plist serialization'''
         dump = read_plist
         with self._sync as sync:
-            sync(dump(d) for d in sync.iterable)
+            sync(dump(d.data) for d in sync.iterable)
         return self
 
 
         '''plist serialization'''
         load = write_plist
         with self._sync as sync:
-            sync(load(d) for d in sync.iterable)
+            sync(load(d.data) for d in sync.iterable)
         return self

File wire/talk/protobufw.py

View file
     def protobuf(self):
         '''protobuf serialization'''
         with self._sync as sync:
-            sync(d.SerializeToString() for d in sync.iterable)
+            sync(d.data.SerializeToString() for d in sync.iterable)
         return self
 
 
             p.ParseFromString(data)
             return p
         with self._sync as sync:
-            sync(load(d) for d in sync.iterable)
+            sync(load(d.data) for d in sync.iterable)
         return self

File wire/talk/thriftw.py

View file
         '''thrift serialization'''
         dumps = serialize
         with self._sync as sync:
-            sync(dumps(d) for d in sync.iterable)
+            sync(dumps(d.data) for d in sync.iterable)
         return self
 
 
         '''thrift serialization'''
         base = kw.get('thrift_base_type')
         with self._sync as sync:
-            sync(deserialize(d, base) for d in sync.iterable)
+            sync(deserialize(d.data, base) for d in sync.iterable)
         return self

File wire/talk/tnetstringw.py

View file
         '''tnetstring serialization'''
         dump = dumps
         with self._sync as sync:
-            sync(dump(d) for d in sync.iterable)
+            sync(dump(d.data) for d in sync.iterable)
         return self
 
 
         '''tnetstring serialization'''
         load = loads
         with self._sync as sync:
-            sync(load(d) for d in sync.iterable)
+            sync(load(d.data) for d in sync.iterable)
         return self

File wire/talk/urlw.py

View file
         '''urlencode serialization'''
         dump = urlencode
         with self._sync as sync:
-            sync(dump(d, **kw) for d in sync.iterable)
+            sync(dump(d.data, **kw) for d in sync.iterable)
         return self
 
 
         '''urlencode serialization'''
         load = self.loads
         with self._sync as sync:
-            sync(load(d, **kw) for d in sync.iterable)
+            sync(load(d.data, **kw) for d in sync.iterable)
         return self

File wire/talk/xmlrpcw.py

View file
 
     def xmlrpc(self, **kw):
         '''xmlrpc serialization'''
-        dumps = dumps
+        dump = dumps
         with self._sync as sync:
-            sync(dumps(d, **kw) for d in sync.iterable)
+            sync(dump(d.data, **kw) for d in sync.iterable)
         return self
 
 
 
     def xmlrpc(self, **kw):
         '''xmlrpc serialization'''
-        loads = loads
+        load = loads
         with self._sync as sync:
-            sync(loads(d, **kw)[0] for d in sync.iterable)
+            sync(load(d.data, **kw)[0] for d in sync.iterable)
         return self

File wire/talk/xmlw.py

View file
     def xml(self, **kw):
         '''xml serialization'''
         with self._sync as sync:
-            sync(tostring(d, **kw) for d in sync.iterable)
+            sync(tostring(d.data, **kw) for d in sync.iterable)
         return self
 
 
     def xml(self, **kw):
         '''xml serialization'''
         with self._sync as sync:
-            sync(fromstring(d, **kw) for d in sync.iterable)
+            sync(fromstring(d.data, **kw) for d in sync.iterable)
         return self

File wire/talk/yamlw.py

View file
         '''yaml serialization'''
         dumps = dump
         with self._sync as sync:
-            sync(dumps(d, **kw) for d in sync.iterable)
+            sync(dumps(d.data, **kw) for d in sync.iterable)
         return self
 
 
         '''yaml serialization'''
         loads = load
         with self._sync as sync:
-            sync(loads(d, **kw) for d in sync.iterable)
+            sync(loads(d.data, **kw) for d in sync.iterable)
         return self