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