Skip to content

Commit 99f1cb6

Browse files
adamwclaude
andcommitted
Fix scalafmt formatting
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
1 parent 2808981 commit 99f1cb6

2 files changed

Lines changed: 1 addition & 3 deletions

File tree

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

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1271,8 +1271,7 @@ class FlowOps[+T]:
12711271
* @param pf
12721272
* A partial function that handles specific exceptions and returns an alternative flow to switch to.
12731273
* @return
1274-
* A flow that emits elements from the upstream flow, and switches to the recovery flow if the upstream fails with a handled
1275-
* exception.
1274+
* A flow that emits elements from the upstream flow, and switches to the recovery flow if the upstream fails with a handled exception.
12761275
*/
12771276
def recoverWith[U >: T](pf: PartialFunction[Throwable, Flow[U]])(using BufferCapacity): Flow[U] = Flow.usingEmitInline: emit =>
12781277
val ch = BufferCapacity.newChannel[U]

core/src/test/scala/ox/flow/FlowOpsOnErrorCompleteTest.scala

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@ package ox.flow
33
import org.scalatest.flatspec.AnyFlatSpec
44
import org.scalatest.matchers.should.Matchers
55

6-
76
class FlowOpsOnErrorCompleteTest extends AnyFlatSpec with Matchers:
87

98
behavior of "Flow.onErrorComplete"

0 commit comments

Comments
 (0)