Source, Flow ve Sink

Akka Streams, bir veri işlem hattını işleme aşamalarından oluşan bir grafik olarak modeller. Üç temel doğrusal aşama şunlardır: Source (öğe üretir), Flow (öğeleri dönüştürür) ve Sink (öğeleri tüketir).

Bir Source'un bir çıkışı, bir Sink'in bir girişi, bir Flow'un ise tam olarak bir girişi ve bir çıkışı vardır. Bunları birbirine bağlamak, ne olması gerektiğini açıklar; ne zaman olacağını değil.

Bir Source[Out, Mat], Out türünde öğeler üretir ve Mat türünde gerçekleştirilmiş bir değer sunar. En basit kaynaklar bellek içi koleksiyonlardan veya aralıklardan oluşturulur.

Akış çalıştırılana kadar Source, serbestçe yeniden kullanılabilen değişmez bir taslaktan ibarettir.

Bir Sink[In, Mat], In türündeki öğeleri tüketir. Gerçekleştirilmiş değer çoğu zaman tüketimin sonucunu içerir; örneğin akış sona erdiğinde tamamlanan bir Future.

Sink.foreach her öğe için bir yan etki çalıştırır; Sink.fold ise tek bir sonuç biriktirir.

Bir Flow[In, Out, Mat], bir Source ile Sink arasında yer alır ve her öğeyi dönüştürür. Flow'lar tek başlarına yeniden kullanılabilir ve herhangi bir uç noktaya bağlanmadan önce birleştirilebilir.

Burada bir Flow, tam sayıları ikiyle çarpar ve dizelere dönüştürür.

via işleci bir Flow'u Source'a bağlar, to ise bir Sink bağlar. Bir Source'u doğrudan to ile bir Sink'e bağlamak, kapalı ve çalıştırılabilir bir taslak olan RunnableGraph üretir.

Henüz hiçbir öğe hareket etmez; bu işlem yalnızca topolojiyi tanımlar.

İşlem hattına bir Flow eklemek için via kullanın. Bir Source.via(flow), çıktı türü Flow'un çıktı türüyle eşleşen yeni bir Source üretir.

via çağrılarını zincirlemek, küçük ve test edilebilir Flow parçalarından uzun dönüşüm işlem hatları oluşturmanızı sağlar.

Derleyici, her aşamanın çıktı türünün bir sonraki aşamanın girdi türüyle eşleşmesini zorunlu kılar. Türü dönüştüren araya eklenmiş bir Flow olmadan Source[Int], Sink[String] ile bağlanamaz.

Bu statik denetim, işlem hattının bağlantı hatalarını çalışma zamanından önce yakalar.

Her taslak bir somutlaştırılmış değer taşır: akış çalıştırıldığında üretilen bir başvuru. Bir Sink.fold, sonucun Future'ını somutlaştırır. Varsayılan olarak aşamaları birleştirmek, en soldaki somutlaştırılmış değeri korur (yalın kaynaklar için NotUsed).

Hangi tarafın değerini istediğinizi seçmek için toMat ve Keep kullanın.

Source'lar, Flow'lar ve Sink'ler değiştirilemez değerler olduğundan, bunları bir kez tanımlayıp birçok işlem hattında yeniden kullanabilirsiniz. Bu yaklaşım, küçük ve adlandırılmış işleme aşamalarından oluşan bir kütüphane oluşturmayı teşvik eder.

Ayrıştırma için tanımlanan bir Flow, hem bir dosya işlem hattına hem de bir HTTP işlem hattına eklenebilir.

Akka Streams birçok Source fabrikasıyla birlikte gelir: zamanlanmış yayım için Source.single, Source.repeat ve Source.tick; bir Future'dan oluşturmak için Source.future ve Source.empty.

Doğru oluşturucuyu seçmek, veri üreticisinin amacını açıkça ifade eder.

Benzer şekilde Sink'ler arasında Sink.head (ilk öğeyi Future olarak döndürür), Sink.seq (tüm öğeleri bir Seq içinde toplar), Sink.ignore (tüketip atar) ve Sink.last bulunur.

Sonucu kodunuza geri aktaran işlem hatlarında en sık Sink.seq ve Sink.fold kullanılır.

Üç doğrusal yapı taşını öğrendiniz: Source üretir, Flow dönüştürür ve Sink tüketir. Bunlar via ve to ile birbirine bağlanan, değiştirilemez ve yeniden kullanılabilir taslaklardır.

Bir Source'u bir Sink'e bağlamak, somutlaştırılmış bir değer taşıyan ancak run çağrılana kadar hiçbir veriyi taşımayan bir RunnableGraph üretir. Sırada, akışları daha zengin işleçlerle dönüştüreceksiniz.