Class: ReactOnRailsPro::StreamRequest

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

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.



123
124
125
126
127
128
129
130
 
# File 'lib/react_on_rails_pro/stream_request.rb', line 123

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 



140
141
142
 
# File 'lib/react_on_rails_pro/stream_request.rb', line 140

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 



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

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

  Sync { consume_with_bundle_reupload(&block) }
end

#http_status ⇒ Object 



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

def http_status = @status

#http_status_recorded? ⇒ Boolean

Returns:

  • (Boolean) 


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

def http_status_recorded? = @status_recorded