ฉันมีช่วงเวลาที่ยากลำบากมากที่จะได้เป็น implicit class
สำหรับ akka.stream.scaladsl.SubFlow
ต้อง compile.
ของฉันทดสอบรหัส:
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
.
argument expression's type is not compatible with formal parameter type