Skip to content

Commit 5dd42f8

Browse files
authored
Final QA (#564)
1 parent da8e557 commit 5dd42f8

File tree

2 files changed

+3
-4
lines changed

2 files changed

+3
-4
lines changed

python-async-iterators/async_csv.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -7,17 +7,16 @@
77
class AsyncCSVIterator:
88
def __init__(self, path):
99
self.path = path
10-
self.file_was_read = False
10+
self.reader = None
1111

1212
def __aiter__(self):
1313
return self
1414

1515
async def __anext__(self):
16-
if not self.file_was_read:
16+
if self.reader is None:
1717
async with aiofiles.open(self.path, mode="r") as file:
1818
lines = await file.readlines()
1919
self.reader = csv.reader(lines)
20-
self.file_was_read = True
2120
try:
2221
return next(self.reader)
2322
except StopIteration:

python-async-iterators/compress.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,5 +18,5 @@ async def main(directory, zip_name="output.zip"):
1818
await archive.write(chunk)
1919

2020

21-
directory = Path()
21+
directory = Path.cwd()
2222
asyncio.run(main(directory))

0 commit comments

Comments
 (0)