Skip to main content

Pipeline

The

Pipeline module facilitates creation of declarative style chained transformations of Streams.

Example

 const username = Stream("Username", StringType);
const password = Stream("Password", StringType);

const pipeline = new PipelineBuilder("BasicAuth")
.from(username)
.error({
if: username => Equal(username, ""),
message: "Username is empty"
})
.input({ name: "password", stream: password })
.warn({
if: (_, { password }) => Equal(password, ""),
message: () => Const("Password is empty")
})
.transform((username, { password }) => StringJoin`${username}:${password}`)
.transform(str => AsciiToBase64(str))
.toTemplate();

Classes

  • BlobPipelineBuilder
  • GenericPipelineBuilder
  • PipelineBuilder
  • TabularPipelineBuilder

On this page