Class: ConcurrentPipeline::Processors::ActorProcessor::Changeset

Inherits:
Object
  • Object
show all
Extended by:
PipeActor
Defined in:
lib/concurrent_pipeline/processors/actor_processor.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from PipeActor

default_block, extended, on_blocks, spawn

Constructor Details

#initialize(dispatch:, store:) ⇒ Changeset

Returns a new instance of Changeset.



170
171
172
173
174
 
# File 'lib/concurrent_pipeline/processors/actor_processor.rb', line 170

def initialize(dispatch:, store:)
  @dispatch = dispatch
  @store = store
  @pipelines = []
end

Instance Attribute Details

#dispatch ⇒ Object (readonly)

Returns the value of attribute dispatch.



169
170
171
 
# File 'lib/concurrent_pipeline/processors/actor_processor.rb', line 169

def dispatch
  @dispatch
end

#pipelines ⇒ Object (readonly)

Returns the value of attribute pipelines.



169
170
171
 
# File 'lib/concurrent_pipeline/processors/actor_processor.rb', line 169

def pipelines
  @pipelines
end

#store ⇒ Object (readonly)

Returns the value of attribute store.



169
170
171
 
# File 'lib/concurrent_pipeline/processors/actor_processor.rb', line 169

def store
  @store
end