2412
2412
self.assertEqual('aaa', stream.next())
2413
2413
self.assertEqual('bbb', stream.next())
2414
2414
exc = self.assertRaises(errors.ErrorFromSmartServer, stream.next)
2415
self.assertEqual(('error', 'Exception', 'Boom!'), exc.error_tuple)
2417
2417
def test_interrupted_by_connection_lost(self):
2418
2418
interrupted_body_stream = (