Function Client

lib/client.js:10–38

(options)

  const EndpointManager = dependencies.EndpointManager;

  function Client (options) {
    this.config = config(options);

    this.endpointManager = new EndpointManager(this.config);
    this.endpointManager.on("wakeup", () => {
      while (this.queue.length > 0) {
        const stream = this.endpointManager.getStream();
        if (!stream) {
          return;
        }
        const resolve = this.queue.shift();
        resolve(stream);
      }

      if (this.shutdownPending) {
        this.endpointManager.shutdown();
      }
    });

    this.endpointManager.on("error", (err) => {
      this.queue.forEach((resolve) => {
        resolve(Promise.reject(err));
      });

      this.queue = [];
    });

    this.queue = [];
  }

  Client.prototype.write = function write (notification, device, count) {
    return this.getStream().then( stream => {