import {PipeListener} from 'datamatic/src/Pipeline/Pipeline.js'

public class | source

PipeListener

Constructor Summary

Public Constructor
public	constructor(target: *)

Member Summary

Public Members
public get	out: Validator: *
public get	target: Pipeline: *
public get	vo: Validator: *

Method Summary

Public Methods
public	complete() closes `pipeline` on complete notification
public	error(e: *)
public	next(data: *): Promise<void\|never>
public	subscribe(handler: *)

Public Constructors

public constructor(target: *) source

Params:

Name	Type	Attribute	Description
target	*

Public Members

public get out: Validator: * source

Return:

Validator

public get target: Pipeline: * source

Return:

Pipeline

public get vo: Validator: * source

Return:

Validator

Public Methods

public complete() source

closes pipeline on complete notification

public error(e: *) source

Params:

Name	Type	Attribute	Description
e	*

public next(data: *): Promise<void|never> source

Params:

Name	Type	Attribute	Description
data	*

Return:

Promise<void|never>

Params:

Name	Type	Attribute	Description
handler	*

PipeListener

Constructor Summary

Member Summary

Method Summary

Public Constructors

public constructor(target: *) source

Params:

Public Members

public get out: Validator: * source

Return:

public get target: Pipeline: * source

Return:

public get vo: Validator: * source

Return:

Public Methods

public complete() source

public error(e: *) source

Params:

public next(data: *): Promise<void|never> source

Params:

Return:

public subscribe(handler: *) source

Params: