mirror of
https://github.com/corundum/corundum.git
synced 2025-01-30 08:32:52 +08:00
merged changes in axis
This commit is contained in:
commit
583849e0db
@ -409,6 +409,7 @@ class AXIStreamSink(object):
|
|||||||
return not self.active
|
return not self.active
|
||||||
|
|
||||||
def wait(self, timeout=0):
|
def wait(self, timeout=0):
|
||||||
|
yield delay(0)
|
||||||
if self.queue:
|
if self.queue:
|
||||||
return
|
return
|
||||||
if timeout:
|
if timeout:
|
||||||
|
@ -114,6 +114,7 @@ class LocalLinkSink(object):
|
|||||||
return not self.queue
|
return not self.queue
|
||||||
|
|
||||||
def wait(self, timeout=0):
|
def wait(self, timeout=0):
|
||||||
|
yield delay(0)
|
||||||
if self.queue:
|
if self.queue:
|
||||||
return
|
return
|
||||||
if timeout:
|
if timeout:
|
||||||
|
Loading…
x
Reference in New Issue
Block a user