Akka akış alt akışı için örtülü sınıf (genel yola bağımlı türler)

0

Soru

Almak için çok zorlanıyorum. implicit class bir için akka.stream.scaladsl.SubFlow derlemek.

Test kodum:

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)
*/ 

Şu ana kadar sahip olduğum örtük sınıf.

  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
      }
    }
  }

Ne yazık ki, örtük sınıf için tanımlamak için uygun genel türleri anlayamıyorum.

Derleyici hatası:

[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)

Alt akış tanımına bakmak: trait SubFlow[+Out, +Mat, +F[+_], C] extends FlowOps[Out, Mat] Yazın için kullanılan örtük sınıf benim genel türlerini tanımlamak için ihtiyacım olan ne anlamıyorum F ve C of the SubFlow.

1

En iyi cevabı

0

Tanımında olduğu gibi daha yüksek tür parametresini kullanmayı deneyin SubFlow

implicit class SideEffectfulSubFlowOps[+Out, +Mat, +FOps[+_], C](val enrichedSubFlow: SubFlow[Out, Mat, FOps, C]) extends AnyVal
2021-10-25 16:13:06

Bunu zaten denedim ve işe yaramıyor. Derleyici hatası: argument expression's type is not compatible with formal parameter type
leozilla

@leozilla çoğaltılamaz. scastie.scala-lang.org/RlTubBvcTQadwh9S7dW7Kw Lütfen bu hatayla derlenmeyen tüm kodu sağlayın.
Dmytro Mitin

scala 2.12.12 olarak değiştirirseniz, artık derlenmez. scastie.scala-lang.org/IIeRtsG1SImlxacl2HzZIA
leozilla

@leozilla Sorun, tür parametrelerinin çıkarılmadığı gibi görünüyor. İlk durumda (açık çağrı ile) belirtilen tür parametreleri kaydedilebilir scastie.scala-lang.org/DmytroMitin/76yS2AG6SMGDrEZZDC9VdA Sorun, bunları uzantı yöntemiyle belirleyememenizdir. Korkarım 2.12'de burada pek bir şey yapılamaz.
Dmytro Mitin

Diğer dillerde

Bu sayfa diğer dillerde

Русский
..................................................................................................................
Italiano
..................................................................................................................
Polski
..................................................................................................................
Română
..................................................................................................................
한국어
..................................................................................................................
हिन्दी
..................................................................................................................
Français
..................................................................................................................
Česk
..................................................................................................................
Português
..................................................................................................................
ไทย
..................................................................................................................
中文
..................................................................................................................
Español
..................................................................................................................
Slovenský
..................................................................................................................