Class: ReactOnRailsPro::StreamRequest

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

Overview

rubocop:disable Metrics/ClassLength

Constant Summary collapse

MAX_PULL_PROP_NAME_LENGTH = 
256

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

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

Returns a new instance of StreamRequest.



126
127
128
129
130
131
132
133
 
# File 'lib/react_on_rails_pro/stream_request.rb', line 126

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

Class Method Details

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



143
144
145
 
# File 'lib/react_on_rails_pro/stream_request.rb', line 143

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

Instance Method Details

#each_chunk(&block) ⇒ Object 



137
138
139
140
141
 
# File 'lib/react_on_rails_pro/stream_request.rb', line 137

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

  Sync { consume_with_bundle_reupload(&block) }
end

#http_status ⇒ Object 



122
 
# File 'lib/react_on_rails_pro/stream_request.rb', line 122

def http_status = @status

#http_status_recorded? ⇒ Boolean

Returns:

  • (Boolean) 


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

def http_status_recorded? = @status_recorded