fix lack of write_eof method

Bug was hidden by exception handling
This commit is contained in:
Alexey Stetsenko
2018-06-08 22:56:53 +03:00
parent 75927b49f5
commit 287eef0a64

View File

@@ -149,6 +149,9 @@ class LayeredStreamWriterBase:
def write(self, data):
return self.upstream.write(data)
def write_eof(self):
return self.upstream.write_eof()
async def drain(self):
return await self.upstream.drain()