Completed
Push — master ( 21f279...d6aafa )
by Maxim
02:34
created
src/Driver.php 1 patch
Braces   +21 added lines, -10 removed lines patch added patch discarded remove patch
@@ -92,10 +92,14 @@  discard block
 block discarded – undo
92 92
 
93 93
         $partials = $this->splitSubscribers();
94 94
 
95
-        foreach ($partials as $provider => $subscribers) {
96
-            try {
95
+        foreach ($partials as $provider => $subscribers)
96
+        {
97
+            try
98
+            {
97 99
                 $this->provider($provider)->send($this->notification, $subscribers);
98
-            } catch (\RuntimeException $e) {
100
+            }
101
+            catch (\RuntimeException $e)
102
+            {
99 103
                 static::emit('flush.exception', $e);
100 104
             }
101 105
         }
@@ -133,20 +137,24 @@  discard block
 block discarded – undo
133 137
         $partials = [];
134 138
 
135 139
         /** @var Subscriber $subscriber */
136
-        foreach ($this->subscribers as $subscriber) {
140
+        foreach ($this->subscribers as $subscriber)
141
+        {
137 142
             $provider = $subscriber->getProvider();
138 143
 
139
-            if (! $this->project->providerConnected($provider)) {
144
+            if (! $this->project->providerConnected($provider))
145
+            {
140 146
                 continue;
141 147
             }
142 148
 
143
-            if (! isset($partials[$provider])) {
149
+            if (! isset($partials[$provider]))
150
+            {
144 151
                 $partials[$provider] = [];
145 152
             }
146 153
 
147 154
             $partials[$provider][] = $subscriber;
148 155
 
149
-            if ($this->payloadStorage) {
156
+            if ($this->payloadStorage)
157
+            {
150 158
                 $this->payloadStorage->assignNotificationToSubscriber(
151 159
                     $subscriber,
152 160
                     $this->notification,
@@ -165,11 +173,13 @@  discard block
 block discarded – undo
165 173
      */
166 174
     protected function validate()
167 175
     {
168
-        if (is_null($this->notification)) {
176
+        if (is_null($this->notification))
177
+        {
169 178
             throw new \RuntimeException("Notification wasn't set.");
170 179
         }
171 180
 
172
-        if (is_null($this->subscribers)) {
181
+        if (is_null($this->subscribers))
182
+        {
173 183
             throw new \RuntimeException('No subscribers set.');
174 184
         }
175 185
     }
@@ -202,7 +212,8 @@  discard block
 block discarded – undo
202 212
      */
203 213
     protected function bootListeners()
204 214
     {
205
-        if (! is_null($this->statisticsStorage)) {
215
+        if (! is_null($this->statisticsStorage))
216
+        {
206 217
             static::$events->useListenerProvider($this->statisticsStorage);
207 218
         }
208 219
     }
Please login to merge, or discard this patch.