module H2::Client::Concurrent
Public Instance Methods
read(maxlen = DEFAULT_MAXLEN)
click to toggle source
# File lib/h2/client/concurrent.rb, line 18 def read maxlen = DEFAULT_MAXLEN main = Thread.current @reader = self.class.thread_pool.post do @read_gate.block! begin _read maxlen rescue => e main.raise e end end end