fixup

Author: santigimeno

src/nsolid/async_ts_queue.h

@@ -236,7 +236,7 @@ class AsyncTSQueue : public std::enable_shared_from_this<AsyncTSQueue<T>> {
 
   // Static callback function for nsuv
   static void async_callback(nsuv::ns_async* handle,
-                           WeakAsyncTSQueue queue_wp) {
+                             WeakAsyncTSQueue queue_wp) {
     SharedAsyncTSQueue queue = queue_wp.lock();
     if (queue == nullptr) {
       return;
@@ -246,6 +246,7 @@ class AsyncTSQueue : public std::enable_shared_from_this<AsyncTSQueue<T>> {
       if (queue->timer_armed_.exchange(false, std::memory_order_acquire) &&
           !queue->queue_.empty()) {
         queue->start_timer();
+        return;
       }
     }