Completed
Push — master ( 21f279...d6aafa )
by Maxim
02:34
created
src/Driver.php 2 patches
Spacing   +3 added lines, -3 removed lines patch added patch discarded remove patch
@@ -136,11 +136,11 @@  discard block
 block discarded – undo
136 136
         foreach ($this->subscribers as $subscriber) {
137 137
             $provider = $subscriber->getProvider();
138 138
 
139
-            if (! $this->project->providerConnected($provider)) {
139
+            if ( ! $this->project->providerConnected($provider)) {
140 140
                 continue;
141 141
             }
142 142
 
143
-            if (! isset($partials[$provider])) {
143
+            if ( ! isset($partials[$provider])) {
144 144
                 $partials[$provider] = [];
145 145
             }
146 146
 
@@ -202,7 +202,7 @@  discard block
 block discarded – undo
202 202
      */
203 203
     protected function bootListeners()
204 204
     {
205
-        if (! is_null($this->statisticsStorage)) {
205
+        if ( ! is_null($this->statisticsStorage)) {
206 206
             static::$events->useListenerProvider($this->statisticsStorage);
207 207
         }
208 208
     }
Please login to merge, or discard this 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.