|
@@ -154,16 +154,21 @@ internal sealed interface ProducerState<T, V> {
|
|
|
|
|
|
|
|
fun createAlreadyFinishedException(cause: Throwable?): IllegalProducerStateException {
|
|
fun createAlreadyFinishedException(cause: Throwable?): IllegalProducerStateException {
|
|
|
val exception = exception
|
|
val exception = exception
|
|
|
|
|
+ val causeMessage = if (cause == null) {
|
|
|
|
|
+ ""
|
|
|
|
|
+ } else {
|
|
|
|
|
+ ", but attempting to finish with the cause $cause"
|
|
|
|
|
+ }
|
|
|
return if (exception == null) {
|
|
return if (exception == null) {
|
|
|
IllegalProducerStateException(
|
|
IllegalProducerStateException(
|
|
|
this,
|
|
this,
|
|
|
- "Producer has already finished normally, but attempting to finish with the cause $cause. Previous state was: $previousState",
|
|
|
|
|
|
|
+ "Producer has already finished normally$causeMessage. Previous state was: $previousState",
|
|
|
cause = cause
|
|
cause = cause
|
|
|
)
|
|
)
|
|
|
} else {
|
|
} else {
|
|
|
IllegalProducerStateException(
|
|
IllegalProducerStateException(
|
|
|
this,
|
|
this,
|
|
|
- "Producer has already finished with the suppressed exception, but attempting to finish with the cause $cause. Previous state was: $previousState",
|
|
|
|
|
|
|
+ "Producer has already finished with the suppressed exception$causeMessage. Previous state was: $previousState",
|
|
|
cause = cause
|
|
cause = cause
|
|
|
).apply {
|
|
).apply {
|
|
|
addSuppressed(exception)
|
|
addSuppressed(exception)
|