Method send

__tests__/flow-control.test.ts:43–54

(size: number)

  // Send a chunk at the current time.
  send(size: number) {
    // The new message begins sending now, unless some other message is still sending, in which
    // case it sends after that message. It occupies the link until all the bytes are sent, based
    // on the bandwidth.
    this.linkOccupiedUntil = Math.max(this.linkOccupiedUntil, this.t) + size / this.bandwidth;

    let { token, shouldBlock } = this.fc.onSend(size);

    // ackTime = time when the chunk finishes writing out to the pipe, plus 1 rtt
    this.inFlight.push({ token, ackTime: this.linkOccupiedUntil + this.rtt });
    this.blocked = shouldBlock;
  }

  // Fill the window by sending chunks of the given size. Returns the number of chunks sent
  // (the last one caused blocking).