summaryrefslogtreecommitdiff
path: root/git/test/test_example.py
diff options
context:
space:
mode:
authorCraig Northway <craig.northway@gmail.com>2014-07-25 11:26:48 +1000
committerCraig Northway <craig.northway@gmail.com>2014-07-25 19:19:22 +1000
commita23d0d8617ba3119069e610fc7b0850a17322726 (patch)
treed8bc5213dd7e7c7f0befdf65afecb13d5435f873 /git/test/test_example.py
parent75194159abce545bfa38c3172efb42da9b0017dc (diff)
downloadgitpython-a23d0d8617ba3119069e610fc7b0850a17322726.tar.gz
Autopep8 fixes with maximum line length 120
Diffstat (limited to 'git/test/test_example.py')
-rw-r--r--git/test/test_example.py28
1 files changed, 14 insertions, 14 deletions
diff --git a/git/test/test_example.py b/git/test/test_example.py
index 1fd87b3f..8a80aac8 100644
--- a/git/test/test_example.py
+++ b/git/test/test_example.py
@@ -7,21 +7,22 @@ from lib import TestBase, fixture_path
from git.base import IStream
from git.db.py.loose import PureLooseObjectODB
from git.util import pool
-
+
from cStringIO import StringIO
from async import IteratorReader
-
+
+
class TestExamples(TestBase):
-
+
def test_base(self):
ldb = PureLooseObjectODB(fixture_path("../../../.git/objects"))
-
+
for sha1 in ldb.sha_iter():
oinfo = ldb.info(sha1)
ostream = ldb.stream(sha1)
assert oinfo[:3] == ostream[:3]
-
+
assert len(ostream.read()) == ostream.size
assert ldb.has_object(oinfo.binsha)
# END for each sha in database
@@ -32,33 +33,32 @@ class TestExamples(TestBase):
except UnboundLocalError:
pass
# END ignore exception if there are no loose objects
-
+
data = "my data"
istream = IStream("blob", len(data), StringIO(data))
-
+
# the object does not yet have a sha
assert istream.binsha is None
ldb.store(istream)
# now the sha is set
assert len(istream.binsha) == 20
assert ldb.has_object(istream.binsha)
-
-
+
# async operation
# Create a reader from an iterator
reader = IteratorReader(ldb.sha_iter())
-
+
# get reader for object streams
info_reader = ldb.stream_async(reader)
-
+
# read one
info = info_reader.read(1)[0]
-
+
# read all the rest until depletion
ostreams = info_reader.read()
-
+
# set the pool to use two threads
pool.set_size(2)
-
+
# synchronize the mode of operation
pool.set_size(0)