docs: public final void drainerFailed(Throwable t) {
          if (t == null) {
              throw new NullPointerException("ConcurrentConveyor.drainerFailed(null)");
          }
          drainer = null;
          drainerDepartureCause = t;
      }