Feature #8119 » rinda.rb.8119.patch
lib/rinda/tuplespace.rb (working copy) | ||
---|---|---|
port.push(entry.value) if port
|
||
@bag.delete(entry)
|
||
notify_event('take', entry.value)
|
||
return entry.value
|
||
return port ? nil : entry.value
|
||
end
|
||
raise RequestExpiredError if template.expired?
|
||
... | ... | |
port.push(entry.value) if port
|
||
@bag.delete(entry)
|
||
notify_event('take', entry.value)
|
||
return entry.value
|
||
return port ? nil : entry.value
|
||
end
|
||
template.wait
|
||
end
|
- « Previous
- 1
- 2
- Next »