File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
reactive/kotlinx-coroutines-reactive/src Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -72,7 +72,7 @@ private class PublisherCoroutine<in T>(
72
72
@Volatile
73
73
private var cancelled = false // true when Subscription.cancel() is invoked
74
74
75
- private var handleException = false // when handleJobException is invoked
75
+ private var shouldHandleException = false // when handleJobException is invoked
76
76
77
77
override val isClosedForSend: Boolean get() = isCompleted
78
78
override val isFull: Boolean = mutex.isLocked
@@ -172,7 +172,7 @@ private class PublisherCoroutine<in T>(
172
172
if (cancelled) {
173
173
// If the parent had failed to handle our exception (handleJobException was invoked), then
174
174
// we must not loose this exception
175
- if (handleException && cause != null ) handleExceptionViaHandler(parentContext, cause)
175
+ if (shouldHandleException && cause != null ) handleExceptionViaHandler(parentContext, cause)
176
176
} else {
177
177
try {
178
178
if (cause != null && cause !is CancellationException )
@@ -236,7 +236,7 @@ private class PublisherCoroutine<in T>(
236
236
// This way we defer decision to handle this exception based on our ability to send this exception
237
237
// to the subscriber (see doLockedSignalCompleted)
238
238
override fun handleJobException (exception : Throwable ) {
239
- handleException = true
239
+ shouldHandleException = true
240
240
}
241
241
242
242
override fun onCompletedExceptionally (exception : Throwable ) {
You can’t perform that action at this time.
0 commit comments