Tee

Tee Source Processor

class TeeSource(app, pipeline, id=None, config=None)[source]

Bases: InternalSource

Description:

class SamplePipeline(bspump.Pipeline):

def __init__(self, app, pipeline_id):
super().__init__(app, pipeline_id)

self.build(
bspump.socket.TCPStreamSource(app, self, config={‘port’: 7000}), bspump.common.TeeProcessor(app, self).bind(“SampleTeePipeline.*TeeSource”), bspump.common.PPrintSink(app, self)

)

class SampleTeePipeline(bspump.Pipeline):

def __init__(self, app, pipeline_id):
super().__init__(app, pipeline_id)

self.build(
bspump.common.TeeSource(app, self), bspump.common.PPrintSink(app, self)

)

TeeSource.__init__()[source]: Description:

Tee Source Method

TeeSource.bind(target)[source]

Description:

Returns

async TeeSource.main()[source]

Description:

Returns

Tee Processor

class TeeProcessor(app, pipeline, id=None, config=None)[source]

Bases: RouterProcessor

Description: See TeeSource for details.

TeeProcessor.__init__()[source]: Description:

Tee Processor Method

TeeProcessor.bind(target: str)[source]

Description: Target is a bspump.PumpService.locate() string

Returns

?

TeeProcessor.unbind(target: str)[source]

Description:

Returns

?

TeeProcessor.process(context, event)[source]

Description:

Returns: event