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 »