ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-02-25 19:11:45 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Minor code formatting

Browse Source
This commit is contained in:
Kyriakos Tharrouniatis 2020-02-12 14:13:05 +00:00
parent cfcca4ac18
commit f27e0641b4
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
core/src/main/kotlin/net/corda/core/internal/FlowSafeSubscriber.kt
View File

@ -23,8 +23,8 @@ class FlowSafeSubscriber<T>(actual: Subscriber<in T>) : SafeSubscriber<T>(actual
override fun onNext(t: T) { override fun onNext(t: T) {
try { try {
actual.onNext(t) actual.onNext(t)
} catch(e: Throwable) { } catch (e: Throwable) {
if(actual is ActionSubscriber) { if (actual is ActionSubscriber) {
// this Subscriber wraps an ActionSubscriber which is always a leaf Observer, then call user-defined onError // this Subscriber wraps an ActionSubscriber which is always a leaf Observer, then call user-defined onError
Exceptions.throwOrReport(e, this) Exceptions.throwOrReport(e, this)
} else { } else {
@ -61,8 +61,7 @@ class FlowSafeSubscriber<T>(actual: Subscriber<in T>) : SafeSubscriber<T>(actual
) )
} }
} }
} }
@VisibleForTesting @VisibleForTesting
class OnNextFailedException(message: String, cause: Throwable): OnErrorNotImplementedException(message, cause) class OnNextFailedException(message: String, cause: Throwable) : OnErrorNotImplementedException(message, cause)