split out delay node grabber
This commit is contained in:
parent
823dbf621f
commit
5c018bcae7
@ -1,9 +1,14 @@
|
|||||||
function cut_forward(v::IVertex)
|
function delays(v::IVertex)
|
||||||
pushes = []
|
ds = []
|
||||||
Flow.prefor(v) do w
|
Flow.prefor(v) do w
|
||||||
value(w) == :Delay &&
|
value(w) == :Delay &&
|
||||||
push!(pushes, vertex(:push!, vertex(:(self.delay)), w[1]))
|
push!(ds, w)
|
||||||
end
|
end
|
||||||
|
return ds
|
||||||
|
end
|
||||||
|
|
||||||
|
function cut_forward(v::IVertex)
|
||||||
|
pushes = map(x->vertex(:push!, vertex(:(self.delay)), v[1]), delays(v))
|
||||||
isempty(pushes) && return v
|
isempty(pushes) && return v
|
||||||
@assert length(pushes) == 1
|
@assert length(pushes) == 1
|
||||||
v = vertex(Flow.Do(), pushes..., v)
|
v = vertex(Flow.Do(), pushes..., v)
|
||||||
|
Loading…
Reference in New Issue
Block a user