Class: ReactOnRailsPro::StreamRequest

Inherits:
Object
  • Object
show all
Defined in:
lib/react_on_rails_pro/stream_request.rb

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(first_chunk_warn_callback: nil, &request_block) ⇒ StreamRequest

Returns a new instance of StreamRequest.



108
109
110
111
112
113
 
# File 'lib/react_on_rails_pro/stream_request.rb', line 108

def initialize(first_chunk_warn_callback: nil, &request_block)
  @request_executor = request_block
  @first_chunk_warn_callback = first_chunk_warn_callback
  @status = nil
  @status_recorded = false
end

Class Method Details

.create(first_chunk_warn_callback: nil, &request_block) ⇒ Object 



123
124
125
 
# File 'lib/react_on_rails_pro/stream_request.rb', line 123

def self.create(first_chunk_warn_callback: nil, &request_block)
  StreamDecorator.new(new(first_chunk_warn_callback: first_chunk_warn_callback, &request_block))
end

Instance Method Details

#each_chunk(&block) ⇒ Object 



117
118
119
120
121
 
# File 'lib/react_on_rails_pro/stream_request.rb', line 117

def each_chunk(&block)
  return enum_for(:each_chunk) unless block

  Sync { consume_with_bundle_reupload(&block) }
end

#http_status ⇒ Object 



100
101
102
 
# File 'lib/react_on_rails_pro/stream_request.rb', line 100

def http_status
  @status
end

#http_status_recorded? ⇒ Boolean

Returns:

  • (Boolean) 


104
105
106
 
# File 'lib/react_on_rails_pro/stream_request.rb', line 104

def http_status_recorded?
  @status_recorded
end