RS compatibility

build.sbt

@@ -112,5 +112,6 @@ lazy val documentation: Project = (project in file("generated-doc")) // importan
   .dependsOn(
     core,
     kafka,
-    mdcLogback
+    mdcLogback,
+    flowReactiveStreams
   )

core/src/main/scala/ox/flow/FlowReactiveOps.scala

@@ -21,7 +21,8 @@ trait FlowReactiveOps[+T]:
 
   /** Converts this [[Flow]] into a [[Publisher]]. The flow is run every time the publisher is subscribed to.
     *
-    * Must be run within a concurrency scope, as upon subscribing, a fork is created to run the publishing process.
+    * Must be run within a concurrency scope, as upon subscribing, a fork is created to run the publishing process. Hence, the scope should
+    * remain active as long as the publisher is used.
     *
     * Elements emitted by the flow are buffered, using a buffer of capacity given by the [[BufferCapacity]] in scope.
     *

doc/streaming/flows.md

@@ -153,4 +153,30 @@ import ox.flow.Flow
 Flow.fromValues(1, 2, 3)
   .tap(n => println(s"Received: $n"))
   .runToList()
+```
+
+## Reactive streams interoperability
+
+A `Flow` can be converted to a `java.util.concurrent.Flow.Publisher` using the `.toPublisher` method.
+
+This needs to be run within an `Ox` concurrency scope, as upon subscribing, a fork is created to run the publishing 
+process. Hence, the scope should remain active as long as the publisher is used.
+
+Internally, elements emitted by the flow are buffered, using a buffer of capacity given by the `BufferCapacity` in 
+scope.
+
+To obtain a `org.reactivestreams.Publisher` instance, you'll need to add the following dependency and import, to 
+bring the `toReactiveStreamsPublisher` method into scope:
+
+```scala mdoc:compile-only
+// sbt dependency: "com.softwaremill.ox" %% "flow-reactive-streams" % "@VERSION@"
+
+import ox.supervised
+import ox.flow.Flow
+import ox.flow.reactive.*
+
+val myFlow: Flow[Int] = ???
+supervised:
+  myFlow.toReactiveStreamsPublisher: org.reactivestreams.Publisher[Int]
+  // use the publisher
 ```

flow-reactive-streams/src/main/scala/ox/flow/reactive/flowReactiveStreamsExtension.scala

@@ -0,0 +1,17 @@
+package ox.flow.reactive
+
+import ox.flow.Flow
+import org.reactivestreams.Publisher
+import ox.Ox
+import ox.channels.BufferCapacity
+import org.reactivestreams.FlowAdapters
+
+extension [A](flow: Flow[A])
+  /** This variant returns an implementation of `org.reactivestreams.Publisher`, as opposed to `java.util.concurrent.Flow.Publisher` which
+    * is supported in the core module.
+    *
+    * @see
+    *   [[Flow.toPublisher]]
+    */
+  def toReactiveStreamsPublisher(using Ox, BufferCapacity): Publisher[A] =
+    FlowAdapters.toPublisher(flow.toPublisher)