@@ -123,7 +123,7 @@ discard block |
||
| 123 | 123 | */ |
| 124 | 124 | public function unpublish(string $streamId) |
| 125 | 125 | { |
| 126 | - $this->publishers = array_filter($this->publishers, function (Publisher $publisher) use ($streamId) { |
|
| 126 | + $this->publishers = array_filter($this->publishers, function(Publisher $publisher) use ($streamId) { |
|
| 127 | 127 | return $streamId !== $publisher->getStreamId(); |
| 128 | 128 | }); |
| 129 | 129 | } |
@@ -135,7 +135,7 @@ discard block |
||
| 135 | 135 | public function unsubscribe(string $streamId) |
| 136 | 136 | { |
| 137 | 137 | if (!empty($this->subscribers)) { |
| 138 | - $this->subscribers = array_filter($this->subscribers, function ($subscriber) use ($streamId) { |
|
| 138 | + $this->subscribers = array_filter($this->subscribers, function($subscriber) use ($streamId) { |
|
| 139 | 139 | if (is_string($subscriber)) { |
| 140 | 140 | return $subscriber !== $streamId; |
| 141 | 141 | } |