Fix #6 behavior.

This commit is contained in:
cheatfate 2018-11-07 22:29:49 +02:00
parent 3160202ffe
commit 190a16da3b
1 changed files with 0 additions and 4 deletions

View File

@ -74,8 +74,6 @@ when defined(windows):
while len(transp.queue) > 0: while len(transp.queue) > 0:
if WritePending in transp.state: if WritePending in transp.state:
## Continuation ## Continuation
if WriteClosed in transp.state:
break
transp.state.excl(WritePending) transp.state.excl(WritePending)
let err = transp.wovl.data.errCode let err = transp.wovl.data.errCode
let vector = transp.queue.popFirst() let vector = transp.queue.popFirst()
@ -133,8 +131,6 @@ when defined(windows):
while true: while true:
if ReadPending in transp.state: if ReadPending in transp.state:
## Continuation ## Continuation
if ReadClosed in transp.state:
break
transp.state.excl(ReadPending) transp.state.excl(ReadPending)
let err = transp.rovl.data.errCode let err = transp.rovl.data.errCode
if err == OSErrorCode(-1): if err == OSErrorCode(-1):