How to use bl - 10 common examples

encodeArgumentsList(argumentsList = []) {
    const bufferList = bl();

    // Trim undefined arguments
    let maxIndex = argumentsList.length - 1;
    while (maxIndex >= 0 && argumentsList[maxIndex] === undefined) {
      maxIndex -= 1;
    }

    // Encode only the necessary values
    for (let i = 0; i <= maxIndex; i += 1) {
      const buffer = this.encode(argumentsList[i]);
      bufferList.append(buffer);
    }

    return bufferList;
  }

function OutgoingMessage(request, send) {
  BufferList.call(this)

  this._packet = {
      messageId: request.messageId
    , token: request.token
    , options: []
    , confirmable: false
    , ack: false
    , reset: false
  }

  var that = this

  if (request.confirmable) {
    // replying in piggyback
    this._packet.ack = true

OutgoingMessage.prototype.end = function(a, b) {
  BufferList.prototype.end.call(this, a, b)

  var packet = this._packet
    , that = this

  packet.code = toCode(this.code || this.statusCode)
  packet.payload = this

  if (this._ackTimer)
    clearTimeout(this._ackTimer)

  this._send(this, packet)

  // easy clean up after generating the packet
  delete this._packet.payload

  return this

import BufferList from "bl";
import { baseOptions } from "../../base";
import { help } from "../../cli/help";
import { Logger } from "../../cli/logger";
import { ParseError } from "../../cli/parse";
import { Context } from "../../cli/types";
import { newCmd } from "../new";

const resolveMock = resolve as jest.Mock;
const requireMock = requireDefault as jest.Mock;

jest.mock("../../cli/help");
jest.mock("@kosko/require");
jest.mock("@kosko/template");

const bl = new BufferList();
const ctx: Context = { logger: new Logger(bl) };

beforeEach(() => jest.resetAllMocks());

describe("when template is not set", () => {
  test("should print help", async () => {
    await newCmd.exec(ctx, []);
    expect(help).toHaveBeenCalledTimes(1);
    expect(help).toHaveBeenCalledWith(newCmd);
  });
});

describe("when template is set", () => {
  describe("and module does not exist", () => {
    const resolveErr = new Error("resolve error");

beforeEach(async () => {
  bl = new BufferList();
  await help(cmd, bl);
});

beforeEach(() => {
  bl = new BufferList();
  print(result, {
    ...options,
    writer: bl
  });
});

return new Promise((resolve, reject) => {
    stream.pipe(bl((err, buf) => {
      if (err) return reject(err)
      resolve(buf)
    }))
  })
}

  decodeArgumentsList(buffer = bl()) {
    const bufferList = buffer instanceof bl ? buffer : bl().append(buffer);
    const argumentsList = [];

    while (bufferList.length) {
      argumentsList.push(this.decode(bufferList));
    }

    return argumentsList;
  }

decodeArgumentsList(buffer = bl()) {
    const bufferList = buffer instanceof bl ? buffer : bl().append(buffer);
    const argumentsList = [];

    while (bufferList.length) {
      argumentsList.push(this.decode(bufferList));
    }

    return argumentsList;
  }

} else if (Buffer.isBuffer(file)) {
          if (!filename) {
            return reject(new Error('文件名未知'))
          }
          name = filename
          type = mime.lookup(name)
          size = file.length
          data = file
          return resolve()
        } else if (file.readable) {
          if (!file.path && !filename) {
            return reject(new Error('文件名未知'))
          }
          name = path.basename(file.path || filename)
          type = mime.lookup(name)
          file.pipe(bl((err, buffer) => {
            if (err) {
              return reject(err)
            }
            size = buffer.length
            data = buffer
            return resolve()
          }))
        }
      }).then(() => {
        ext = name.match(/.*\.(.*)/)