Class: Relaxo::QueryServer::MappingProcess

Inherits:
Process
  • Object
show all
Defined in:
lib/relaxo/query_server/mapper.rb

Overview

Supports Mapper by providing a context with an emit method that collects the results from the mapping function.

Instance Method Summary collapse

Methods inherited from Process

#call, #log

Constructor Details

#initialize(context, mapper, function) ⇒ MappingProcess

Returns a new instance of MappingProcess.



28
29
30
31
32
33
 
# File 'lib/relaxo/query_server/mapper.rb', line 28

def initialize(context, mapper, function)
	super(context, function)
	
	@mapper = mapper
	@results = []
end

Instance Method Details

#emit(key, value = nil) ⇒ Object

Emit a result



36
37
38
 
# File 'lib/relaxo/query_server/mapper.rb', line 36

def emit(key, value = nil)
	@results << [key, value]
end

#load(name) ⇒ Object 



40
41
42
 
# File 'lib/relaxo/query_server/mapper.rb', line 40

def load(name)
	@mapper.load(name)
end

#run(*args) ⇒ Object 



44
45
46
47
48
49
50
51
52
53
 
# File 'lib/relaxo/query_server/mapper.rb', line 44

def run(*args)
	begin
		call(*args)
	rescue Exception => exception
		# If the mapping function throws an error, report the error for this document:
		return @context.error_for_exception(exception)
	end
	
	return @results
end