public static < T > MultipleStreamSource < T > ofMultiple ( final QueueFactory < ? > q ) { Objects . requireNonNull ( q ) ; return new MultipleStreamSource < T > ( StreamSource . of ( q ) . createQueue ( ) ) ; }
Construct a StreamSource that supports multiple readers of the same data backed by a Queue created from the supplied QueueFactory