bad-lib-code.scala

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

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
      _ = badLibrary.executeOperation() // also unplugged.. or is it? ;)
    } yield response
  }
}