Merge pull request #91 from Gizra/88-remove-range

#88 - Remove unused/risky range early exit.

message_subscribe.module

@@ -73,23 +73,13 @@ function message_subscribe_message_subscribe_get_subscribers(MessageInterface $m
     $result = $query->execute();
 
     foreach ($result as $row) {
-
       $debug && \Drupal::logger('message_subscribe')->debug(
         'Subscriber row flag_id: @flag_id user: @uid',
         ['@flag_id' => $row->flag_id, '@uid' => $row->uid]
       );
       $uids[$row->uid] = !empty($uids[$row->uid]) ? $uids[$row->uid] : new DeliveryCandidate([], [], $row->uid);
       // Register the flag name.
       $uids[$row->uid]->addFlag($row->flag_id);
-
-      if ($range) {
-        --$range;
-        if ($range == 0) {
-          // We've reach the requested item.
-          \Drupal::logger('message_subscribe')->debug('Exiting hook early as range was reached. Last uid to process @uid', ['@uid' => $row->uid]);
-          return $uids;
-        }
-      }
     }
   }
   $debug && \Drupal::logger('message_subscribe')->debug(

src/Subscribers.php

@@ -162,10 +162,6 @@ public function sendMessage(EntityInterface $entity, MessageInterface $message,
       $message->save();
     }
 
-    if ($use_queue) {
-      $id = $entity->id();
-    }
-
     if ($use_queue && empty($subscribe_options['queue'])) {
       if (empty($message->id())) {
         throw new MessageSubscribeException('Cannot add a non-saved message to the queue.');