refactor(simulator): Separate push and pull flags

This change separates the push and pull flags in
FlowConsumerContextImpl, meaning that sources can now push directly
without pulling and vice versa.

1 files changed, 0 insertions, 17 deletions

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 061ebea6..380fd38a 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
@@ -28,7 +28,6 @@ import org.junit.jupiter.api.*
 import org.opendc.simulator.core.runBlockingSimulation
 import org.opendc.simulator.flow.internal.FlowConsumerContextImpl
 import org.opendc.simulator.flow.internal.FlowEngineImpl
-import org.opendc.simulator.flow.source.FixedFlowSource
 
 /**
  * A test suite for the [FlowConsumerContextImpl] class.
@@ -56,22 +55,6 @@ class FlowConsumerContextTest {
     }
 
     @Test
-    fun testIntermediateFlush() = runBlockingSimulation {
-        val engine = FlowEngineImpl(coroutineContext, clock)
-        val consumer = FixedFlowSource(1.0, 1.0)
-
-        val logic = spyk(object : FlowConsumerLogic {})
-        val context = FlowConsumerContextImpl(engine, consumer, logic)
-        context.capacity = 1.0
-
-        context.start()
-        delay(1) // Delay 1 ms to prevent hitting the fast path
-        engine.scheduleSync(engine.clock.millis(), context)
-
-        verify(exactly = 2) { logic.onPush(any(), any(), any(), any()) }
-    }
-
-    @Test
     fun testDoubleStart() = runBlockingSimulation {
         val engine = FlowEngineImpl(coroutineContext, clock)
         val consumer = object : FlowSource {