diff --git a/core/src/main/kotlin/net/corda/core/internal/FlowSafeSubscriber.kt b/core/src/main/kotlin/net/corda/core/internal/FlowSafeSubscriber.kt index 6ce853d027..06b139ed76 100644 --- a/core/src/main/kotlin/net/corda/core/internal/FlowSafeSubscriber.kt +++ b/core/src/main/kotlin/net/corda/core/internal/FlowSafeSubscriber.kt @@ -65,7 +65,7 @@ class FlowSafeSubscriber(actual: Subscriber) : SafeSubscriber(actual /** * We throw [OnNextFailedException] to pass the exception back through the preceding [Subscriber] chain - * without triggering any [SafeSubscriber.onError]s. Since we extending an [OnErrorNotImplementedException] + * without triggering any [SafeSubscriber.onError]s. Since we are extending an [OnErrorNotImplementedException] * the exception will be re-thrown at [Exceptions.throwOrReport]. */ @VisibleForTesting