pipeline.app Module

class wpull.pipeline.app.AppSession(factory: wpull.application.factory.Factory, args, stderr)[source]

Bases: object

class wpull.pipeline.app.AppSource(session: wpull.pipeline.app.AppSession)[source]

Bases: wpull.pipeline.pipeline.ItemSource

get_item() → typing.Union[source]
wpull.pipeline.app.new_encoded_stream(args, stream)[source]

Return a stream writer.