title: How can I create reactor Flux from a blocking queue?
body: <p>I am trying to implement a reactor Flux created from a BlockingQueue but not sure which operator is best for my use case?</p>
  
  <p>I am creating a streaming REST end point, where response is Flux that needs to keep emitting messages from a BlockingQueue as a response to GET REST call. </p>
  
  <p>I have already tried forums and documentation and can only find Flux initiated from iterable collections or reactive data sources, but no examples from any BlockingQueue.</p>