Avoid potential race condition between close/drain events when piping

DaveRandom · DaveRandom · commit fb80499400d4 · 2014-06-11T17:27:28.000+01:00
diff --git a/src/Stream.php b/src/Stream.php
@@ -50,7 +50,9 @@ public function pause()
 
     public function resume()
     {
-        $this->loop->addReadStream($this->stream, array($this, 'handleData'));
+        if ($this->readable) {
+            $this->loop->addReadStream($this->stream, array($this, 'handleData'));
+        }
     }
 
     public function write($data)

Original file line number	Diff line number	Diff line change
`@@ -50,7 +50,9 @@ public function pause()`
`50`	`50`
`51`	`51`	`public function resume()`
`52`	`52`	`{`
`53`		`- $this->loop->addReadStream($this->stream, array($this, 'handleData'));`
	`53`	`+ if ($this->readable) {`
	`54`	`+ $this->loop->addReadStream($this->stream, array($this, 'handleData'));`
	`55`	`+ }`
`54`	`56`	`}`
`55`	`57`
`56`	`58`	`public function write($data)`