good-api.scala

import scala.concurrent.ExecutionContext.Implicits.global
import scala.concurrent.{ExecutionContext, Future}

trait Request

trait Response

trait CacheService {
  def myOwnEc: ExecutionContext

  def isDuplicateRequest(request: Request): Future[Option[Request]]

  def setCacheForDeduplication(dedupedReq: Option[Request]): Future[Boolean]
}

trait Processor {
  def process(request: Option[Request])(implicit ec: ExecutionContext): Future[Response]
}

class API(cacheService: CacheService, processor: Processor) {

  def process(request: Request): Future[Response] = {
    for {
      dedupedRequest <- cacheService.isDuplicateRequest(request)
      response <- processor.process(dedupedRequest)
      _ = cacheService.setCacheForDeduplication(dedupedRequest) // now unplugged from the flow
    } yield response
  }
}