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.



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

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 



136
137
138
 
# File 'lib/react_on_rails_pro/stream_request.rb', line 136

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

Instance Method Details

#each_chunk(&block) ⇒ Object 



130
131
132
133
134
 
# File 'lib/react_on_rails_pro/stream_request.rb', line 130

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

  Sync { consume_with_bundle_reupload(&block) }
end

#http_status ⇒ Object 



113
114
115
 
# File 'lib/react_on_rails_pro/stream_request.rb', line 113

def http_status
  @status
end

#http_status_recorded? ⇒ Boolean

Returns:

  • (Boolean) 


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

def http_status_recorded?
  @status_recorded
end