refactor(simulator): Remove transform from SimResourceForwarder

This change removes the ability to transform the duration of a pull from
the SimResourceForwarder class. This ability is not used anymore, since
pushes are now done using a method instead of a command.

1 files changed, 2 insertions, 16 deletions

diff --git a/opendc-simulator/opendc-simulator-resources/src/test/kotlin/org/opendc/simulator/resources/SimResourceTransformerTest.kt b/opendc-simulator/opendc-simulator-resources/src/test/kotlin/org/opendc/simulator/resources/SimResourceForwarderTest.kt
index d7d0924f..49e60f68 100644
--- a/opendc-simulator/opendc-simulator-resources/src/test/kotlin/org/opendc/simulator/resources/SimResourceTransformerTest.kt
+++ b/opendc-simulator/opendc-simulator-resources/src/test/kotlin/org/opendc/simulator/resources/SimResourceForwarderTest.kt
@@ -33,9 +33,9 @@ import org.opendc.simulator.resources.consumer.SimWorkConsumer
 import org.opendc.simulator.resources.impl.SimResourceInterpreterImpl
 
 /**
- * A test suite for the [SimResourceTransformer] class.
+ * A test suite for the [SimResourceForwarder] class.
  */
-internal class SimResourceTransformerTest {
+internal class SimResourceForwarderTest {
     @Test
     fun testCancelImmediately() = runBlockingSimulation {
         val forwarder = SimResourceForwarder()
@@ -199,20 +199,6 @@ internal class SimResourceTransformerTest {
     }
 
     @Test
-    fun testTransformExit() = runBlockingSimulation {
-        val forwarder = SimResourceTransformer { ctx, _ -> ctx.close(); Long.MAX_VALUE }
-        val scheduler = SimResourceInterpreterImpl(coroutineContext, clock)
-        val source = SimResourceSource(1.0, scheduler)
-
-        val consumer = spyk(SimWorkConsumer(2.0, 1.0))
-        source.startConsumer(forwarder)
-        forwarder.consume(consumer)
-
-        assertEquals(0, clock.millis())
-        verify(exactly = 1) { consumer.onNext(any(), any(), any()) }
-    }
-
-    @Test
     fun testCounters() = runBlockingSimulation {
         val forwarder = SimResourceForwarder()
         val scheduler = SimResourceInterpreterImpl(coroutineContext, clock)