code: @Override
      public void applyAction(@NotNull WireOut outWire) {
  
          applyAction(outWire.bytes());
  
          for (int y = 1; y < 1000; y++) {
  
              long pos = outWire.bytes().writePosition();
  
              for (int i = 0; i < consumers.size(); i++) {
  
                  if (outWire.bytes().writePosition() > TcpChannelHub.SAFE_TCP_SIZE)
                      return;
  
                  if (isClosed())
                      return;
  
                  WireOutConsumer c = next();
  
                  try {
                      c.accept(outWire);
                  } catch (InvalidEventHandlerException e) {
                      consumers.remove(c);
                  } catch (InterruptedException e) {
                      Thread.currentThread().interrupt();
                      Jvm.warn().on(getClass(), e);
                      return;
                  }
              }
  
              if (pos == outWire.bytes().writePosition())
                  return;
  
          }
  
          Jvm.warn().on(getClass(), new IllegalStateException("loop when too long"));
  
      }
docs: Apply waiting messages and return false if there was none.
  
  @param outWire buffer to write to.