docs: public static <T> MultipleStreamSource<T> ofMultiple(final int backPressureAfter) {
          return new MultipleStreamSource<T>(
                                             StreamSource.of(backPressureAfter)
                                                         .createQueue());
      }