streamDrainer (StreamDrainer)

This processor resolves the stream and then creates a new empty stream. Resolving the stream acts as a signal for any upstream lazy evaluation letting it know that it should be processed now.

Class names

scala: code.model.flows.processors.utils.StreamDrainerProcessorScannable
javascript: code_model_flows_processors_utils_StreamDrainerProcessorScannable

Aliases

Input type

Output type

Config

{"bindingHint":"Forces the flowstream to resolve and then creates a new empty stream.","categories":[{"defaultCollapsed":true,"fields":["testData","testDataTransformFunc","assertionFunc"],"name":"Testing"}],"fieldName":"streamDrainer","fields":[{"default":null,"fieldName":"streamDrainer.name","hidden":false,"hideLabel":false,"name":"name","readonly":false,"renderStrategies":[],"type":"S","validators":[]},{"default":"streamDrainer","fieldName":"streamDrainer.classPath","hidden":false,"hideLabel":false,"name":"classPath","readonly":false,"renderStrategies":[],"type":"S","validators":[]},{"default":null,"fieldName":"streamDrainer.testDataTransformFunc","hidden":false,"hideLabel":false,"name":"testDataTransformFunc","readonly":false,"renderStrategies":[],"type":"Js","validators":[]},{"default":"${generatedId}","fieldName":"streamDrainer.id","hidden":false,"hideLabel":false,"name":"id","readonly":false,"renderStrategies":[],"type":"S","validators":[]},{"default":null,"fieldName":"streamDrainer.testData","hidden":false,"hideLabel":false,"name":"testData","readonly":false,"renderStrategies":[],"type":"Jv","validators":[]},{"default":null,"fieldName":"streamDrainer.assertionFunc","hidden":false,"hideLabel":false,"name":"assertionFunc","readonly":false,"renderStrategies":[],"type":"Js","validators":[]}],"hidden":false,"hideLabel":false,"label":"streamDrainer","name":"streamDrainer","readonly":false,"renderStrategies":[],"type":"O"}