reactor-core/src/main/java/reactor/util/concurrent/Queues.java
@SuppressWarnings("unchecked")
	public static <T> Supplier<Queue<T>> unbounded(int linkSize) {
		if (linkSize == XS_BUFFER_SIZE) {
			return XS_UNBOUNDED;
		}
		else if (linkSize == Integer.MAX_VALUE || linkSize == SMALL_BUFFER_SIZE) {
			return unbounded();
		}
		return  () -> new SpscLinkedArrayQueue<>(linkSize);
	}
@SuppressWarnings("unchecked")
	public static <T> Supplier<Queue<T>> unbounded(int linkSize) {
		if (linkSize == XS_BUFFER_SIZE) {
			return XS_UNBOUNDED;
		}
		else if (linkSize == Integer.MAX_VALUE || linkSize == SMALL_BUFFER_SIZE) {
			return unbounded();
		}
		return  () -> new SpscLinkedArrayQueue<>(linkSize);
	}
@ SuppressWarnings ( "unchecked" ) public static < T > Supplier < Queue < T > > unbounded ( int linkSize ) { if ( linkSize == XS_BUFFER_SIZE ) { return XS_UNBOUNDED ; } else if ( linkSize == Integer . MAX_VALUE || linkSize == SMALL_BUFFER_SIZE ) { return unbounded ( ) ; } return ( ) -> new SpscLinkedArrayQueue <> ( linkSize ) ; }
Returns an unbounded, linked-array-based Queue. Integer.max sized link will
return the default {@link #SMALL_BUFFER_SIZE} size.
@param linkSize the link size
@param <T> the reified {@link Queue} generic type
@return an unbounded {@link Queue} {@link Supplier}
Returns an unbounded linked - array - based Queue . Integer . max sized link will return the default {