diff --git a/node/src/main/kotlin/net/corda/node/internal/FlowSafeSubject.kt b/node/src/main/kotlin/net/corda/node/internal/FlowSafeSubject.kt
index 3880e5bce6..9c63bdedde 100644
--- a/node/src/main/kotlin/net/corda/node/internal/FlowSafeSubject.kt
+++ b/node/src/main/kotlin/net/corda/node/internal/FlowSafeSubject.kt
@@ -9,7 +9,7 @@ import rx.subjects.Subject
 
 /**
  * [FlowSafeSubject] is used to unwrap an [Observer] from a [SafeSubscriber], re-wrap it with a [FlowSafeSubscriber]
- * and then subscribe it to its underlying [Subject]. It is only used therefore, to provide its underlying [Subject] with
+ * and then subscribe it to its underlying [Subject]. It is only used, to provide its underlying [Subject] with
  * subscribing of non unsubscribing [rx.Observer]s.
  *
  * Upon [rx.Observable.subscribe] it will wrap everything that is a non [SafeSubscriber] with a [FlowSafeSubscriber] the same way