Module: H2::Client::Concurrent

Included in:
H2::Client
Defined in:
lib/h2/client/concurrent.rb

Defined Under Namespace

Modules: ClassMethods

Instance Method Summary collapse

Instance Method Details

#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
    reading!
    begin
      _read maxlen
    rescue => e
      main.raise e
    end
  end
end