2424
2525from async import IteratorReader
2626
27- from io import StringIO
27+ from io import BytesIO
2828
2929from struct import pack
3030
@@ -44,7 +44,7 @@ def _assert_object_writing_simple(self, db):
4444 ni = 250
4545 for i in range (ni ):
4646 data = pack (">L" , i )
47- istream = IStream (str_blob_type , len (data ), StringIO (data ))
47+ istream = IStream (str_blob_type , len (data ), BytesIO (data ))
4848 new_istream = db .store (istream )
4949 assert new_istream is istream
5050 assert db .has_object (istream .binsha )
@@ -82,7 +82,7 @@ def _assert_object_writing(self, db):
8282 prev_ostream = db .set_ostream (ostream )
8383 assert type (prev_ostream ) in ostreams or prev_ostream in ostreams
8484
85- istream = IStream (str_blob_type , len (data ), StringIO (data ))
85+ istream = IStream (str_blob_type , len (data ), BytesIO (data ))
8686
8787 # store returns same istream instance, with new sha set
8888 my_istream = db .store (istream )
@@ -132,8 +132,9 @@ def _assert_object_writing_async(self, db):
132132 ni = 5000
133133 def istream_generator (offset = 0 , ni = ni ):
134134 for data_src in xrange (ni ):
135- data = str (data_src + offset )
136- yield IStream (str_blob_type , len (data ), StringIO (data ))
135+ print (type (data_src ), type (offset ))
136+ data = bytes (data_src + offset )
137+ yield IStream (str_blob_type , len (data ), BytesIO (data ))
137138 # END for each item
138139 # END generator utility
139140
0 commit comments