diff --git a/‎lib/handler/cache-revalidation-handler.js‎
Lines changed: 12 additions & 10 deletions b/‎lib/handler/cache-revalidation-handler.js‎
Lines changed: 12 additions & 10 deletions
diff --git a/‎lib/interceptor/cache.js‎
Lines changed: 7 additions & 1 deletion b/‎lib/interceptor/cache.js‎
Lines changed: 7 additions & 1 deletion
@@ -19,26 +19,26 @@ const DecoratorHandler = require('../handler/decorator-handler')
 class CacheRevalidationHandler extends DecoratorHandler {
   #successful = false
   /**
-   * @type {(() => void)}
+   * @type {((boolean) => void)}
    */
-  #successCallback
+  #callback
   /**
    * @type {(import('../../types/dispatcher.d.ts').default.DispatchHandlers)}
    */
   #handler
 
   /**
-   * @param {() => void} successCallback Function to call if the cached value is valid
+   * @param {(boolean) => void} callback Function to call if the cached value is valid
    * @param {import('../../types/dispatcher.d.ts').default.DispatchHandlers} handler
    */
-  constructor (successCallback, handler) {
-    if (typeof successCallback !== 'function') {
-      throw new TypeError('successCallback must be a function')
+  constructor (callback, handler) {
+    if (typeof callback !== 'function') {
+      throw new TypeError('callback must be a function')
     }
 
     super(handler)
 
-    this.#successCallback = successCallback
+    this.#callback = callback
     this.#handler = handler
   }
 
@@ -107,9 +107,9 @@ class CacheRevalidationHandler extends DecoratorHandler {
    * @param {string[] | null} rawTrailers
    */
   onComplete (rawTrailers) {
-    if (this.#successful) {
-      this.#successCallback()
-    } else if (typeof this.#handler.onComplete === 'function') {
+    this.#callback(this.#successful)
+
+    if (!this.#successful && typeof this.#handler.onComplete === 'function') {
       this.#handler.onComplete(rawTrailers)
     }
   }
@@ -120,6 +120,8 @@ class CacheRevalidationHandler extends DecoratorHandler {
    * @param {Error} err
    */
   onError (err) {
+    this.#callback(false)
+
     if (typeof this.#handler.onError === 'function') {
       this.#handler.onError(err)
     }
 
@@ -146,7 +146,13 @@ module.exports = (opts = {}) => {
                 }
               },
               new CacheRevalidationHandler(
-                () => respondWithCachedValue(stream, value),
+                (success) => {
+                  if (success) {
+                    respondWithCachedValue(stream, value)
+                  } else {
+                    stream.on('error', () => {}).destroy()
+                  }
+                },
                 new CacheHandler(globalOpts, opts, handler)
               )
             )
Original file line number	Diff line number	Diff line change
`@@ -146,7 +146,13 @@ module.exports = (opts = {}) => {`
`146`	`146`	`}`
`147`	`147`	`},`
`148`	`148`	`new CacheRevalidationHandler(`
`149`		`- () => respondWithCachedValue(stream, value),`
	`149`	`+ (success) => {`
	`150`	`+ if (success) {`
	`151`	`+ respondWithCachedValue(stream, value)`
	`152`	`+ } else {`
	`153`	`+ stream.on('error', () => {}).destroy()`
	`154`	`+ }`
	`155`	`+ },`
`150`	`156`	`new CacheHandler(globalOpts, opts, handler)`
`151`	`157`	`)`
`152`	`158`	`)`