Commit75c4afe

authored

Merge pull request#213 from mehaase/trio_fix

Fix bug in Trio's `_read_exactly()`

2 parents3d075c2 +99423c0 commit75c4afeCopy full SHA for 75c4afe

File tree

-1

lines changed

-1

lines changed

Lines changed: 4 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -237,8 +237,11 @@ async def _read_until(self, delimiter):`
`237`	`237`	`returnbytes(buffer)`
`238`	`238`
`239`	`239`	`asyncdef_read_exactly(self,num):`
	`240`	`+data=b''`
`240`	`241`	`try:`
`241`		`-returnawaitself._stream.receive_some(num)`
	`242`	`+whilelen(data)<num:`
	`243`	`+data+=awaitself._stream.receive_some(num-len(data))`
	`244`	`+returndata`
`242`	`245`	`except (trio.BrokenResourceError,trio.ClosedResourceError):`
`243`	`246`	`self._closed=True`
`244`	`247`

Comments

(0)