암시적 위한 클래스 akka 스트림 SubFlow(일반적인 경로를 따라 종)

나는 힘든 시간을 얻 implicit class 대 akka.stream.scaladsl.SubFlow 를 컴파일.

테스트 코드:

val subFlow = Source(List("1", "2", "3"))
  .groupBy(1, f)

val richSubFlow = new SideEffectfulSubFlowOps(subFlow)

val got = richSubFlow
  .withSideEffect((elem: String) => recordedItems.add(elem))
  .mergeSubstreams
  .to(Sink.seq)

/* In the end I would like to write it like this:
val got = Source(List("1", "2", "3"))
  .groupBy(1, f)
  .withSideEffect((elem: String) => recordedItems.add(elem))
  .mergeSubstreams
  .to(Sink.seq)
*/ 

암시적 반합니다.

  implicit class SideEffectfulSubFlowOps[+Out, +Mat, FOps <: FlowOps[Out, Mat], C](val enrichedSubFlow: SubFlow[Out, Mat, FOps#Repr, C]) extends AnyVal {

    def withSideEffect(f: Out => Unit): enrichedSubFlow.Repr[Out] = {
      enrichedSubFlow.map { o =>
        f(o)
        o
      }
    }
  }

불행하게도 내가 알아낼 수 없습니다 적절한 일반적인 유형에 대해 정의하는 암시적인 클래스입니다.

컴파일러에 오류가:

[error] SubFlowExtensionsSpec.scala:21:43: type mismatch;
[error]  found   : akka.stream.scaladsl.SubFlow[String,akka.NotUsed,[+O]akka.stream.scaladsl.Source[O,akka.NotUsed],akka.stream.scaladsl.RunnableGraph[akka.NotUsed]]
[error]  required: akka.stream.scaladsl.SubFlow[?,?,?#Repr,?]
[error]       val x = new SideEffectfulSubFlowOps(subFlow)

보고서 정의 subflow: trait SubFlow[+Out, +Mat, +F[+_], C] extends FlowOps[Out, Mat] 나는 어떻게 이해해야의 일반적인 유형에 암시 등에 사용되는 종류 F 고 C 의 SubFlow.