Remove invalid comment

adamw · adamw · commit 13cc98866177 · 2024-12-17T16:26:59.000+01:00
diff --git a/core/src/main/scala/ox/flow/FlowRunOps.scala b/core/src/main/scala/ox/flow/FlowRunOps.scala
@@ -23,8 +23,6 @@ trait FlowRunOps[+T]:
     *
     * Must be run within a concurrency scope as a fork is created to run the flow. The size of the buffer is determined by the
     * [[BufferCapacity]] that is in scope.
-    *
-    * Blocks until the flow completes.
     */
   def runToChannel()(using OxUnsupervised, BufferCapacity): Source[T] =
     // if the previous stage is a source, there's no point in creating a new channel & fork, just to copy data

Original file line number	Diff line number	Diff line change
`@@ -23,8 +23,6 @@ trait FlowRunOps[+T]:`
`23`	`23`	`*`
`24`	`24`	`* Must be run within a concurrency scope as a fork is created to run the flow. The size of the buffer is determined by the`
`25`	`25`	`* [[BufferCapacity]] that is in scope.`
`26`		`- *`
`27`		`- * Blocks until the flow completes.`
`28`	`26`	`*/`
`29`	`27`	`def runToChannel()(using OxUnsupervised, BufferCapacity): Source[T] =`
`30`	`28`	`// if the previous stage is a source, there's no point in creating a new channel & fork, just to copy data`