1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
require 'concurrent/maybe'
require 'concurrent/utility/monotonic_time'
module Concurrent
class Channel
class Selector
class AfterClause
def initialize(seconds, block)
raise ArgumentError.new('timeout must 0.0 or more') if seconds.to_f < 0.0
@end = Concurrent.monotonic_time + seconds.to_f
@block = block
end
def execute
if Concurrent.monotonic_time > @end
result = @block ? @block.call : nil
Concurrent::Maybe.just(result)
else
Concurrent::Maybe.nothing
end
end
end
end
end
end
|
