Method enqueueEvent

src/remote/appServer/client.ts:505–537

(event: RemoteAppServerEvent)

  }

  private enqueueEvent(event: RemoteAppServerEvent): void {
    if (this.skippedEvents > 0) {
      const lagged: RemoteAppServerEvent = {
        type: 'lagged',
        skipped: this.skippedEvents,
      }
      if (appServerEventRequiresDelivery(event)) {
        if (!this.events.pushLossless(lagged)) {
          this.close('remote app-server event consumer channel is closed')
          return
        }
        this.skippedEvents = 0
      } else if (this.events.tryPush(lagged)) {
        this.skippedEvents = 0
      } else {
        this.skippedEvents += 1
        void this.rejectIfServerRequestDropped(event)
        return
      }
    }

    if (appServerEventRequiresDelivery(event)) {
      if (!this.events.pushLossless(event)) {
        this.close('remote app-server event consumer channel is closed')
      }
      return
    }

    if (!this.events.tryPush(event)) {
      this.skippedEvents += 1
      void this.rejectIfServerRequestDropped(event)
    }
  }

  private async rejectIfServerRequestDropped(
    event: RemoteAppServerEvent,