Skip to content

Commit f7aff20

Browse files
authored
Merge pull request #34 from keorn/abstract-put
UnionAll Put
2 parents 414e329 + ee30e5f commit f7aff20

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

src/resources/stores.jl

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@ struct StorePutKey{T} <: ResourceKey
22
priority :: Int
33
id :: UInt
44
item :: T
5+
StorePutKey{T}(priority, id, item) where T = new(priority, id, item)
56
end
67

78
struct StoreGetKey <: ResourceKey
@@ -28,7 +29,7 @@ end
2829

2930
function Put{T}(sto::Store{T}, item::T; priority::Int=0) :: Put
3031
put_ev = Put(sto.env)
31-
sto.put_queue[put_ev] = StorePutKey(priority, sto.seid+=one(UInt), item)
32+
sto.put_queue[put_ev] = StorePutKey{T}(priority, sto.seid+=one(UInt), item)
3233
@callback trigger_get(put_ev, sto)
3334
trigger_put(put_ev, sto)
3435
return put_ev

0 commit comments

Comments
 (0)