Skip to content

Commit d02a9d6

Browse files
committed
Merge branch 'refs/heads/resume-race'
2 parents 178146f + fb80499 commit d02a9d6

File tree

2 files changed

+71
-1
lines changed

2 files changed

+71
-1
lines changed

CHANGELOG.md

Lines changed: 68 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,68 @@
1+
# Changelog
2+
3+
## 0.4.1 (2014-04-13)
4+
5+
* Bug fix: v0.3.4 changes merged for v0.4.1
6+
7+
## 0.3.4 (2014-03-30)
8+
9+
* Bug fix: [Stream] Fixed 100% CPU spike from non-empty write buffer on closed stream
10+
11+
## 0.4.0 (2014-02-02)
12+
13+
* BC break: Bump minimum PHP version to PHP 5.4, remove 5.3 specific hacks
14+
* BC break: Update to Evenement 2.0
15+
* Dependency: Autoloading and filesystem structure now PSR-4 instead of PSR-0
16+
17+
## 0.3.3 (2013-07-08)
18+
19+
* Bug fix: [Stream] Correctly detect closed connections
20+
21+
## 0.3.2 (2013-05-10)
22+
23+
* Bug fix: [Stream] Make sure CompositeStream is closed properly
24+
25+
## 0.3.1 (2013-04-21)
26+
27+
* Bug fix: [Stream] Allow any `ReadableStreamInterface` on `BufferedSink::createPromise()`
28+
29+
## 0.3.0 (2013-04-14)
30+
31+
* Feature: [Stream] Factory method for BufferedSink
32+
33+
## 0.2.6 (2012-12-26)
34+
35+
* Version bump
36+
37+
## 0.2.5 (2012-11-26)
38+
39+
* Feature: Make BufferedSink trigger progress events on the promise (@jsor)
40+
41+
## 0.2.4 (2012-11-18)
42+
43+
* Feature: Added ThroughStream, CompositeStream, ReadableStream and WritableStream
44+
* Feature: Added BufferedSink
45+
46+
## 0.2.3 (2012-11-14)
47+
48+
* Version bump
49+
50+
## 0.2.2 (2012-10-28)
51+
52+
* Version bump
53+
54+
## 0.2.1 (2012-10-14)
55+
56+
* Bug fix: Check for EOF in `Buffer::write()`
57+
58+
## 0.2.0 (2012-09-10)
59+
60+
* Version bump
61+
62+
## 0.1.1 (2012-07-12)
63+
64+
* Bug fix: Testing and functional against PHP >= 5.3.3 and <= 5.3.8
65+
66+
## 0.1.0 (2012-07-11)
67+
68+
* First tagged release

src/Stream.php

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,9 @@ public function pause()
5050

5151
public function resume()
5252
{
53-
$this->loop->addReadStream($this->stream, array($this, 'handleData'));
53+
if ($this->readable) {
54+
$this->loop->addReadStream($this->stream, array($this, 'handleData'));
55+
}
5456
}
5557

5658
public function write($data)

0 commit comments

Comments
 (0)