Class: Fray::ResponsePipe

Inherits:

AbortablePipe

• Object
• AbortablePipe
• Fray::ResponsePipe

Defined in:

lib/fray/response_pipe.rb

Instance Method Summary

• #initialize(thens = [], c = nil) ⇒ ResponsePipe constructor

  A new instance of ResponsePipe.

Methods inherited from AbortablePipe

#catch, #run, #then

Constructor Details

#initialize(thens = [], c = nil) ⇒ ResponsePipe

Returns a new instance of ResponsePipe.

# File 'lib/fray/response_pipe.rb', line 32

def initialize(thens = [], c = nil)
  abort_predicate = ->(state) { state.is_a?(Fray::Data::Response) }
  super(abort_predicate, thens, c)
end