diff options
| author | Fabian Mastenbroek <mail.fabianm@gmail.com> | 2021-01-11 22:14:51 +0100 |
|---|---|---|
| committer | Fabian Mastenbroek <mail.fabianm@gmail.com> | 2021-01-12 13:15:52 +0100 |
| commit | ce4b9bd28d9cb24b112a3a4723252c5bbca2fe5b (patch) | |
| tree | cc5ec033251045b4d0ef2c9ff909324698c3b113 | |
| parent | e9278df42673deaeace0d85337ac1434ec6c081d (diff) | |
Properly close EventStream on close call
This change fixes an issue where an EventStream was not properly closed
when the user asked so.
| -rw-r--r-- | simulator/opendc-trace/opendc-trace-core/src/main/kotlin/org/opendc/trace/core/internal/AbstractEventStream.kt | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/simulator/opendc-trace/opendc-trace-core/src/main/kotlin/org/opendc/trace/core/internal/AbstractEventStream.kt b/simulator/opendc-trace/opendc-trace-core/src/main/kotlin/org/opendc/trace/core/internal/AbstractEventStream.kt index 1887ad7a..fac99664 100644 --- a/simulator/opendc-trace/opendc-trace-core/src/main/kotlin/org/opendc/trace/core/internal/AbstractEventStream.kt +++ b/simulator/opendc-trace/opendc-trace-core/src/main/kotlin/org/opendc/trace/core/internal/AbstractEventStream.kt @@ -124,7 +124,7 @@ internal abstract class AbstractEventStream : EventStream { } override fun close() { - if (state != StreamState.Closed) { + if (state == StreamState.Closed) { return } |