flux Akka Parse à la source

Question

Je veux analyser

val flow : FlowOps = Source(1 to 10).map(_+1) 

à un Source mais ressemble il n'y a pas une façon simple. Je l'ai fait cette solution de contournement

Source.fromGraph(

     GraphDSL.create() { builder => 

     val flow = Source(1 to 10).map(_+1) 

     SourceShape(builder.add(flow).out) 
     } 
    ) 

Semble surpuissant pour transformer un flux simple à un graphique juste pour obtenir à nouveau un flux simple. Y a-t-il un moyen plus simple?

Answer 1

Si je comprends bien, vous voulez utiliser Source(1 to 10).map(_ + 1) comme une valeur de type Source[Int, _], non? Mais vous n'avez pas besoin de faire quelque chose de spécial pour cela, car map() renvoie déjà un Source du type approprié. Si vous écrivez juste

val source = Source(1 to 10).map(_ + 1) 

alors source aura le type Source[Int, NotUsed]. Vous pouvez le vérifier facilement en mettant la signature appropriée explicitement:

val source: Source[Int, NotUsed] = Source(1 to 10).map(_ + 1) 

Je ne suis même pas sûr de savoir pourquoi vous avez utilisé FlowOps annotation de type tout. Comme le suggère son scaladoc, FlowOps fait partie de l'API interne akka-stream et ne devrait pas être utilisé en dehors de la bibliothèque elle-même.