Sha256: 70c7e239aa11d2967043612ac57009c01db97f4f297eeedc208245e701bf822c
Contents?: true
Size: 1.15 KB
Versions: 110
Compression:
Stored size: 1.15 KB
Contents
module Files
class SizableIO < IO
def self.pipe
r, w = super
w.instance_variable_set(:@read_io, r)
[ r, w ]
end
def size
read_io.content_length_promise.wait.value
end
def wait!(timeout=nil)
read_io.ready_promise.wait(timeout)
error!
self
end
def fulfill_content_length(length)
read_io.content_length = length
read_io.content_length_promise.execute
end
def ready!
read_io.ready_promise.execute
end
def close
raise @with_error if @with_error
super
read_io.content_length_promise.try_set(nil)
read_io.ready_promise.try_set(true)
end
def error!
raise read_io.with_error if read_io.with_error
end
def set_error(e)
read_io.with_error = e
end
protected
attr_accessor :content_length, :with_error
def content_length_promise
@content_length_promise ||= Concurrent::Promise.new { content_length }
end
def ready_promise
@ready_promise ||= Concurrent::Promise.new { true }
end
def read_io
@read_io || self
end
def read_io?
read_io == self
end
end
end
Version data entries
110 entries across 110 versions & 1 rubygems