Method get

ui/socket.js:252–334

* Return a stream handler * * @param {object} callbacks A group of callbacks to call when needed * * @returns {Promise } The stream manager *

(callbacks)

   *
   */
  async get(callbacks) {
    let self = this;

    if (this.streamHandler) {
      return this.streamHandler;
    }

    callbacks.connecting();

    let streamPaused = false,
      currentReceived = 0,
      currentUnpacked = 0;

    const shouldPause = () => {
      return currentReceived > currentUnpacked;
    };

    try {
      let conn = await this.dial.dial({
        inbound(data) {
          currentReceived += data.size;

          callbacks.traffic(data.size, 0);
        },
        inboundUnpacked(data) {
          currentUnpacked += data.length;

          if (currentUnpacked >= currentReceived) {
            currentUnpacked = 0;
            currentReceived = 0;
          }

          if (self.streamHandler !== null) {
            if (streamPaused && !shouldPause()) {
              streamPaused = false;
              self.streamHandler.resume();

              return;
            } else if (!streamPaused && shouldPause()) {
              streamPaused = true;
              self.streamHandler.pause();

              return;
            }
          }
        },
        outbound(data) {
          callbacks.traffic(0, data.length);
        }
      });

      let streamHandler = new streams.Streams(conn.reader, conn.sender, {
        echoInterval: self.echoInterval,
        echoUpdater(delay) {
          return callbacks.echo(delay);
        },
        cleared(e) {
          if (self.streamHandler === null) {