X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/45f10d80d1b584808a6e375214b5be6bc7d2a730..b04638275cff9b393e1bc04136d44f361b999cf8:/sdk/python/tests/test_stream.py?ds=sidebyside diff --git a/sdk/python/tests/test_stream.py b/sdk/python/tests/test_stream.py index 6c3bd61414..082af1bb7c 100644 --- a/sdk/python/tests/test_stream.py +++ b/sdk/python/tests/test_stream.py @@ -70,13 +70,16 @@ class StreamFileReaderTestCase(unittest.TestCase): def test_seek_min_zero(self): sfile = self.make_count_reader() - sfile.seek(-2, os.SEEK_SET) + self.assertEqual(0, sfile.tell()) + with self.assertRaises(IOError): + sfile.seek(-2, os.SEEK_SET) self.assertEqual(0, sfile.tell()) def test_seek_max_size(self): sfile = self.make_count_reader() sfile.seek(2, os.SEEK_END) - self.assertEqual(9, sfile.tell()) + # POSIX permits seeking past end of file. + self.assertEqual(11, sfile.tell()) def test_size(self): self.assertEqual(9, self.make_count_reader().size()) @@ -184,6 +187,19 @@ class StreamFileReaderTestCase(unittest.TestCase): def test_bz2_decompression(self): self.check_decompression('bz2', bz2.compress) + def test_readline_then_readlines(self): + reader = self.make_newlines_reader() + data = reader.readline() + self.assertEqual('one\n', data) + data = reader.readlines() + self.assertEqual(['two\n', '\n', 'three\n', 'four\n', '\n'], data) + + def test_readline_then_readall(self): + reader = self.make_newlines_reader() + data = reader.readline() + self.assertEqual('one\n', data) + self.assertEqual(''.join(['two\n', '\n', 'three\n', 'four\n', '\n']), ''.join(reader.readall())) + class StreamRetryTestMixin(object): # Define reader_for(coll_name, **kwargs)