Wrapper to create an outToSource function

OutputStreamUtils.scala

object OutputStreamUtils {
  def outToSource(queueSize: Int)(f: OutputStream => Unit)(implicit S: Strategy): Process[Task, ByteVector] = {
    val queue = async.boundedQueue[ByteVector](queueSize)
    val qos = new QueueOutputStream(queue)

    S(f(qos))

    queue.dequeue
  }
}