override fun <D : Operation.Data> intercept(
  request: ApolloRequest<D>,
  chain: ApolloInterceptorChain,
): Flow<ApolloResponse<D>> {
  return chain.proceed(request).map { response ->
    if (notAplicableHere) return@map response // If nothing to intercept just return it as it was
    // do something else with the response if applicable
    response // ^map return the response as it was if we reached the end of the map
  }
}

onEach

...
  return chain.proceed(request).onEach { response ->
    if (response.notApplicablehere) return@onEach
    //do something
  }

class SunsettingInterceptor: ApolloInterceptor {
  override fun <D : Operation.Data> intercept(request: ApolloRequest<D>, chain: ApolloInterceptorChain): Flow<ApolloResponse<D>> {
    return chain.proceed(request).onEach {
      if (it.errors?.any { it.isSunsetError() } == true) {
        ForceUpgradeActivity.newInstance(context)
      }
    }
  }

  private fun Error.isSunsetError(): Boolean {
    return nonStandardFields?.get("errorCode") == "invalid_version"
  }
}