@@ -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 | } |