@@ 89-98 (lines=10) @@ | ||
86 | /** |
|
87 | * @inheritdoc |
|
88 | */ |
|
89 | public function removeReadStream($stream) : self |
|
90 | { |
|
91 | $key = (int) $stream; |
|
92 | if (isset($this->readEvents[$key])) { |
|
93 | $this->readEvents[$key]->stop(); |
|
94 | unset($this->readEvents[$key]); |
|
95 | } |
|
96 | ||
97 | return $this; |
|
98 | } |
|
99 | ||
100 | /** |
|
101 | * @inheritdoc |
|
@@ 103-112 (lines=10) @@ | ||
100 | /** |
|
101 | * @inheritdoc |
|
102 | */ |
|
103 | public function removeWriteStream($stream) : self |
|
104 | { |
|
105 | $key = (int) $stream; |
|
106 | if (isset($this->writeEvents[$key])) { |
|
107 | $this->writeEvents[$key]->stop(); |
|
108 | unset($this->writeEvents[$key]); |
|
109 | } |
|
110 | ||
111 | return $this; |
|
112 | } |
|
113 | ||
114 | /** |
|
115 | * @inheritdoc |