docs: public static StreamSource of(final QueueFactory<?> q) {
          Objects.requireNonNull(q);
          return new StreamSource() {
              @SuppressWarnings("unchecked")
              @Override
              <T> Queue<T> createQueue() {
                  return (Queue<T>) q.build();
  
              }
          };
      }