अंतर्निहित वर्ग के लिए अक्का धारा 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.