From 4f5a1f88d0c6aa19ce4cab0ec7b9b13a24c92fbe Mon Sep 17 00:00:00 2001
From: Fabian Mastenbroek <mail.fabianm@gmail.com>
Date: Thu, 30 Sep 2021 14:45:42 +0200
Subject: refactor(simulator): Remove capacity event

This change removes the Capacity entry from FlowEvent. Since the source
is always pulled on a capacity change, we do not need a separate event
for this.
---
 .../test/kotlin/org/opendc/simulator/flow/FlowConsumerContextTest.kt    | 2 +-
 .../src/test/kotlin/org/opendc/simulator/flow/FlowForwarderTest.kt      | 2 +-
 .../src/test/kotlin/org/opendc/simulator/flow/FlowSinkTest.kt           | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

(limited to 'opendc-simulator/opendc-simulator-flow/src/test')

diff --git a/opendc-simulator/opendc-simulator-flow/src/test/kotlin/org/opendc/simulator/flow/FlowConsumerContextTest.kt b/opendc-simulator/opendc-simulator-flow/src/test/kotlin/org/opendc/simulator/flow/FlowConsumerContextTest.kt
index f1a5cbe4..fe39eb2c 100644
--- a/opendc-simulator/opendc-simulator-flow/src/test/kotlin/org/opendc/simulator/flow/FlowConsumerContextTest.kt
+++ b/opendc-simulator/opendc-simulator-flow/src/test/kotlin/org/opendc/simulator/flow/FlowConsumerContextTest.kt
@@ -99,6 +99,6 @@ class FlowConsumerContextTest {
         context.start()
         context.capacity = 4200.0
 
-        verify(exactly = 0) { consumer.onEvent(any(), any(), FlowEvent.Capacity) }
+        verify(exactly = 1) { consumer.onPull(any(), any(), any()) }
     }
 }
diff --git a/opendc-simulator/opendc-simulator-flow/src/test/kotlin/org/opendc/simulator/flow/FlowForwarderTest.kt b/opendc-simulator/opendc-simulator-flow/src/test/kotlin/org/opendc/simulator/flow/FlowForwarderTest.kt
index d125c638..7fae918a 100644
--- a/opendc-simulator/opendc-simulator-flow/src/test/kotlin/org/opendc/simulator/flow/FlowForwarderTest.kt
+++ b/opendc-simulator/opendc-simulator-flow/src/test/kotlin/org/opendc/simulator/flow/FlowForwarderTest.kt
@@ -197,7 +197,7 @@ internal class FlowForwarderTest {
         }
 
         assertEquals(3000, clock.millis())
-        verify(exactly = 1) { consumer.onEvent(any(), any(), FlowEvent.Capacity) }
+        verify(exactly = 1) { consumer.onPull(any(), any(), any()) }
     }
 
     @Test
diff --git a/opendc-simulator/opendc-simulator-flow/src/test/kotlin/org/opendc/simulator/flow/FlowSinkTest.kt b/opendc-simulator/opendc-simulator-flow/src/test/kotlin/org/opendc/simulator/flow/FlowSinkTest.kt
index 010a985e..5d579e5d 100644
--- a/opendc-simulator/opendc-simulator-flow/src/test/kotlin/org/opendc/simulator/flow/FlowSinkTest.kt
+++ b/opendc-simulator/opendc-simulator-flow/src/test/kotlin/org/opendc/simulator/flow/FlowSinkTest.kt
@@ -67,7 +67,7 @@ internal class FlowSinkTest {
             provider.capacity = 0.5
         }
         assertEquals(3000, clock.millis())
-        verify(exactly = 1) { consumer.onEvent(any(), any(), FlowEvent.Capacity) }
+        verify(exactly = 1) { consumer.onPull(any(), any(), any()) }
     }
 
     @Test
-- 
cgit v1.2.3