Method: H2::Client::Concurrent#read

Defined in:
lib/h2/client/concurrent.rb

#read(maxlen = DEFAULT_MAXLEN) ⇒ Object 



18
19
20
21
22
23
24
25
26
27
28
 
# 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