Skip to content

Commit 3232271

Browse files
committed
Improve coverage
1 parent 858af21 commit 3232271

2 files changed

Lines changed: 6 additions & 2 deletions

File tree

pystreamapi/_streams/error/__error.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ def _itr(self, src, mapper=nothing, condition=true_condition) -> list:
5555
raise e
5656
if self.__error_level == ErrorLevel.IGNORE:
5757
continue
58-
if self.__error_level == ErrorLevel.WARN:
58+
else:
5959
self.__log(e)
6060
return new_src
6161

@@ -77,7 +77,7 @@ def _one(self, mapper=nothing, condition=true_condition, item=None):
7777
raise e
7878
if self.__error_level == ErrorLevel.IGNORE:
7979
return _sentinel
80-
if self.__error_level == ErrorLevel.WARN:
80+
else:
8181
self.__log(e)
8282
return _sentinel
8383

tests/test_error_handler.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -62,6 +62,10 @@ def test_one_raise_with_condition(self):
6262
self.assertRaises(ValueError, lambda: self.handler._one(int, lambda x: x != "",
6363
"a"))
6464

65+
def test_one_condition_false(self):
66+
self.handler.error_level(ErrorLevel.RAISE)
67+
self.assertEqual(self.handler._one(int, lambda x: x == "", "1"), _sentinel)
68+
6569
def test_one_ignore(self):
6670
self.handler.error_level(ErrorLevel.IGNORE)
6771
self.assertEqual(self.handler._one(mapper=int, item="a"), _sentinel)

0 commit comments

Comments
 (0)