The next generation of enterprise integration.

public sealed class Hl7LabOrderSplitter    : PipelineComponentBase<Hl7Config>{    public override string Name => "fnHl7LabOrderSplitter";     // Disassemble the HL7 batch, then split per order    protected override async Task<PipelineComponentOutput> ExecuteAsync(        PipelineComponentInput input, Hl7Config config, CancellationToken ct)    {        var json   = Hl7.Disassemble(input.Body, config.CanonicalSchema);        var orders = json.SelectTokens("$.orders[*]");        return PipelineComponentOutput.Split(orders);    }}

public sealed class EdiDebatcher    : PipelineComponentBase<EdiConfig>{    public override string Name => "fnEdiDebatcher";     // Decode, debatch the interchange, disassemble by EDI type    protected override async Task<PipelineComponentOutput> ExecuteAsync(        PipelineComponentInput input, EdiConfig config, CancellationToken ct)    {        var raw         = Convert.FromBase64String(input.AsString());        var interchange = Edi.Debatch(raw);        var messages    = interchange.Select(tx => Edi.Disassemble(tx, tx.DetectType()));        return PipelineComponentOutput.Many(messages);    }}

public sealed class BankWireGate    : PipelineComponentBase<WireConfig>{    public override string Name => "fnBankWireGate";     // Decrypt with the key parameter, validate, forward or throw    protected override async Task<PipelineComponentOutput> ExecuteAsync(        PipelineComponentInput input, WireConfig config, CancellationToken ct)    {        var wire = Crypto.Decrypt(input.Body, config.DecryptionKey);        if (!Wire.IsValid(wire, out var error))            throw new PipelineException(error);        return PipelineComponentOutput.Single(wire);    }}