export default {
  async fetch(request, env, ctx) {
    // ... stuff
  },
};

export class ServiceLayerEntryPoint extends WorkerEntrypoint {
  async getKvValue(key: string) {
    return await this.env.KV.get(key);
  }
}

export default {
  async fetch(request, env, ctx) {
    // ... stuff
  },
};

export class ServiceLayerEntryPoint extends WorkerEntrypoint {
  async getKvValue(key: string) {
    return await this.env.KV.get(key);
  }
}

export default {
  async fetch(request, env, ctx) {
    const kvKey = 'somevalue';
    const kvValueFromService = await executeRpcWithCleanup(() => env.SERVICE.getKvValue(kvKey));
  },
};

export default {
  async fetch(request, env, ctx) {
    const kvKey = 'somevalue';
    const kvValueFromService = await executeRpcWithCleanup(() => env.SERVICE.getKvValue(kvKey));
  },
};

/**
 * Executes an RPC call and ensures proper cleanup.
 * @param {Function} rpcCall - A function that performs the RPC call.
 * @returns {Promise<any>} - The result of the RPC call.
 */
export async function executeRpcWithCleanup(rpcCall) {
  let rpcResult = null;
  try {
    rpcResult = await rpcCall();
    return rpcResult;
  } finally {
    if (rpcResult && typeof rpcResult[Symbol.dispose] === 'function') {
      // console.info('Disposing RPC result');
      rpcResult[Symbol.dispose]();
    } else {
      // console.info('No Symbol.dispose method on rpcResult');
    }
  }
}

/**
 * Executes an RPC call and ensures proper cleanup.
 * @param {Function} rpcCall - A function that performs the RPC call.
 * @returns {Promise<any>} - The result of the RPC call.
 */
export async function executeRpcWithCleanup(rpcCall) {
  let rpcResult = null;
  try {
    rpcResult = await rpcCall();
    return rpcResult;
  } finally {
    if (rpcResult && typeof rpcResult[Symbol.dispose] === 'function') {
      // console.info('Disposing RPC result');
      rpcResult[Symbol.dispose]();
    } else {
      // console.info('No Symbol.dispose method on rpcResult');
    }
  }
}

await executeRpcWithCleanup(() => env.SERVICE.myFunction());

await executeRpcWithCleanup(() => env.SERVICE.myFunction());