code: @Override
      public void registerLimit(final long limit) {
  
          if (queues.size() > 0) {
              if (unlimited.get(currentQueue())
                           .get())
                  limits.get(currentQueue())
                        .set(0);
  
              limits.get(currentQueue())
                    .addAndGet(limit);
              unlimited.get(currentQueue())
                       .set(false);
  
              queues.stream()
                    .forEach(this::closeQueueIfFinishedStateless);
  
          }
      }
docs: /* (non-Javadoc)
  @see Continueable#registerLimit(long)