reactor-core/src/main/java/reactor/core/publisher/UnicastProcessor.java
public static <E> UnicastProcessor<E> create(Queue<E> queue, Disposable endcallback) {
		return new UnicastProcessor<>(queue, endcallback);
	}
public static <E> UnicastProcessor<E> create(Queue<E> queue, Disposable endcallback) {
		return new UnicastProcessor<>(queue, endcallback);
	}
Create a new {@link UnicastProcessor} that will buffer on a provided queue in an
unbounded fashion.

@param queue the buffering queue
@param endcallback called on any terminal signal
@param <E> the relayed type
@return a unicast {@link FluxProcessor}