Package com.rpl.rama.test

Class MockOutputCollector

java.lang.Object

com.rpl.rama.test.MockOutputCollector

All Implemented Interfaces:

OutputCollector

public class MockOutputCollector
extends Object
implements OutputCollector

Helper utility for unit testing a RamaOperation outside the context of a module or Block. Emits from the operation are captured in internal state in this object and can be retrieved for performing assertions.

See Also:

• Testing documentation

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MockOutputCollector.CapturedEmit	Information about a captured emit

Constructor Summary

Constructors

Constructor	Description
MockOutputCollector()

Method Summary

Modifier and Type	Method	Description
void	emit(Object... output)	Emit any number of fields to the default output stream.
void	emitStream(String streamName, Object... output)	Emit any number of fields to a named output stream.
List<MockOutputCollector.CapturedEmit>	getEmits()	Retrieve captured emits in the order in which they happened
Map<String,List<List<Object>>>	getEmitsByStream()	Retrieve captured emits split by stream name.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MockOutputCollector

public MockOutputCollector()

Method Details

emit

public void emit(Object... output)

Description copied from interface: OutputCollector

Emit any number of fields to the default output stream. This emit can be captured with Block.Out.out(String...)

Specified by:

emit in interface OutputCollector

Parameters:

output - Output fields

emitStream

public void emitStream(String streamName,
 Object... output)

Description copied from interface: OutputCollector

Emit any number of fields to a named output stream. This emit can be captured with Block.MultiOutImpl.outStream(String, String, String...)

Specified by:

emitStream in interface OutputCollector

Parameters:

streamName - Name of output stream

output - Output fields

getEmits

public List<MockOutputCollector.CapturedEmit> getEmits()

Retrieve captured emits in the order in which they happened

getEmitsByStream

public Map<String,List<List<Object>>> getEmitsByStream()

Retrieve captured emits split by stream name. The stream name for calls to OutputCollector.emit(java.lang.Object...) will be null.