1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
class StreamInterface(Interface):
    def __init__(self, signature, *, path):
        super().__init__(signature, path = path)

        if signature.backpressure == False:
            self.ready = C(1)
    
    async def recv(self, sim):
        await self.ready.set(1)
        await sim.tick().until(self.valid)
        
        payload = await self.payload.get()

        await sim.tick()
        await self.ready.set(0)

        return payload

    async def send(self, sim, value):
        await self.payload.set(value)

        await self.valid.set(1)
        await sim.tick().until(self.ready)

        await sim.tick()
        await self.valid.set(0)