mirror of
https://github.com/urbit/shrub.git
synced 2024-12-15 04:22:48 +03:00
get rid of fin.bay
This commit is contained in:
parent
ce120f8ce1
commit
6239ed87ea
@ -43,7 +43,6 @@
|
|||||||
deh/deps :: dephash definitions
|
deh/deps :: dephash definitions
|
||||||
sup/(jug @uvH duct) :: hash listeners
|
sup/(jug @uvH duct) :: hash listeners
|
||||||
out/(set beam) :: listening beams
|
out/(set beam) :: listening beams
|
||||||
fin/(set beam) :: updated beams
|
|
||||||
== ::
|
== ::
|
||||||
++ deps ::
|
++ deps ::
|
||||||
$: def/(map @uvH (set beam)) :: hash obligations
|
$: def/(map @uvH (set beam)) :: hash obligations
|
||||||
@ -195,7 +194,6 @@
|
|||||||
~|([%bad-dep &2.sih] !!)
|
~|([%bad-dep &2.sih] !!)
|
||||||
?~ p.sih +> :: acknowledged
|
?~ p.sih +> :: acknowledged
|
||||||
=. out.bay (~(del in out.bay) bem)
|
=. out.bay (~(del in out.bay) bem)
|
||||||
=. fin.bay (~(put in fin.bay) bem)
|
|
||||||
=/ des ~(tap in (~(get ju bak.deh.bay) bem))
|
=/ des ~(tap in (~(get ju bak.deh.bay) bem))
|
||||||
|- ^+ this
|
|- ^+ this
|
||||||
?~ des this
|
?~ des this
|
||||||
@ -260,8 +258,6 @@
|
|||||||
^+ this
|
^+ this
|
||||||
?: (~(has by sup.bay) dep)
|
?: (~(has by sup.bay) dep)
|
||||||
this(sup.bay (~(put ju sup.bay) dep hen))
|
this(sup.bay (~(put ju sup.bay) dep hen))
|
||||||
?: (~(any in bes) ~(has in fin.bay))
|
|
||||||
this(mow :_(mow [hen %give %news dep]))
|
|
||||||
=. sup.bay (~(put ju sup.bay) dep hen)
|
=. sup.bay (~(put ju sup.bay) dep hen)
|
||||||
::
|
::
|
||||||
=> .(bes ~(tap in bes))
|
=> .(bes ~(tap in bes))
|
||||||
@ -283,9 +279,9 @@
|
|||||||
=> .(bes ~(tap in bes))
|
=> .(bes ~(tap in bes))
|
||||||
|- ^+ this
|
|- ^+ this
|
||||||
?~ bes this
|
?~ bes this
|
||||||
?: |(!(~(has in out.bay) i.bes) (~(has in fin.bay) i.bes))
|
?. (~(has in out.bay) i.bes)
|
||||||
:: already cancelled/received
|
:: already cancelled
|
||||||
::REVIEW assert that unrecieved subs open?
|
::REVIEW assert instead?
|
||||||
$(bes t.bes)
|
$(bes t.bes)
|
||||||
?: (~(any in (~(get ju bak.deh.bay) i.bes)) ~(has by sup.bay))
|
?: (~(any in (~(get ju bak.deh.bay) i.bes)) ~(has by sup.bay))
|
||||||
::REVIEW performance questionable
|
::REVIEW performance questionable
|
||||||
@ -1917,10 +1913,9 @@
|
|||||||
cache+[%| (turn `(list term)`/hood/bake/slit/slim/slap/slam cache-for)]
|
cache+[%| (turn `(list term)`/hood/bake/slit/slim/slap/slam cache-for)]
|
||||||
::
|
::
|
||||||
:+ %depends %| :~
|
:+ %depends %| :~
|
||||||
hashes+[%& deh]
|
definitions+[%& deh]
|
||||||
listeners+[%& sup]
|
listeners+[%& sup]
|
||||||
waiting+[%& out]
|
waiting+[%& out]
|
||||||
resolved+[%& fin]
|
|
||||||
==
|
==
|
||||||
::
|
::
|
||||||
tasks+[%& dym tad]
|
tasks+[%& dym tad]
|
||||||
|
Loading…
Reference in New Issue
Block a user