अक्का को mat

Question

मैं समझने के लिए अक्का स्ट्रीमिंग में Tomat करता है कोशिश कर रहा हूँ स्ट्रीम। उदाहरण के लिए:

val sink1:Sink[Int, Future[Int]]=Sink.fold[Int,Int](0)(_ + _) 

val flow=Flow[Int].fold[Int](0){(x,y)=> x+y} 

val runnable = Source (1 to 10).viaMat(flow)(Keep.right).toMat(sink1)(Keep.both) 

1. क्या viaMat के उपयोग के माध्यम बनाम है?
2. क्या है को mat को mat को viaMat के बीच कर रहा है?
3. क्या keep.both का प्रयोग होता है, इसका मतलब यह है कि मैं मान हो सकता है यदि हाँ तो कैसे मैं उन मूल्यों को वापस प्राप्त कर सकते पिछले और मौजूदा से materialized।

धन्यवाद अरुण

Answer 1

1. के माध्यम से सिर्फ viaMat (...) (Keep.left) के लिए एक शॉर्टकट है, और वास्तव में यह है कि यह कैसे लागू किया गया है: override def via[T, Mat2](flow: Graph[FlowShape[Out, T], Mat2]): Repr[T] = viaMat(flow)(Keep.left)

2. को mat viaMat के समान है लेकिन सिंक के लिए, यह आपको भौतिक मूल्य को बाएं (स्रोत/प्रवाह) या दाएं (सिंक) पक्ष से या

3. Keep.both केवल एक अल है ias (a:A,b:B) => (a, b) के लिए, यह एक ऐसा फ़ंक्शन है जो दो इनपुट पैरामीटर लेता है और उन्हें टुपल के रूप में वापस कर देता है।

   // you're keeping the materialized value of flow 
   val source2 = Source (1 to 10).viaMat(flow)(Keep.right) 
   // you're keeping both materialized values, i.e. the one of flow from previous step 
   // and the one o sink.  
   val runnableGraph = source2.toMat(sink)(Keep.both) 
   runnableGraph.run() // returns a tuple (flowMatVal, sinkMatVal) 
   

   : यह है जब दो प्रवाह के संयोजन दोनों को छोड़ दिया और सही पक्ष के materialized मूल्य के लिए (या स्रोत और प्रवाह या प्रवाह और सिंक आदि)

मैं कोड के अपने लाइन काटना जाएगा प्रयोग किया जाता है

आप एक प्रवाह के दो हिस्सों में शामिल होने के (यानी स्रोत और प्रवाह/सिंक या प्रवाह और सिंक) उनमें से हर एक materialized मूल्य है कि आप जब आप प्रवाह चलाने है जब। बाएं तरफ रखते हुए/से संयोजन करते समय डिफ़ॉल्ट व्यवहार। यदि आपमैट/toMat के माध्यम से उपयोग करते हैं तो आप सही भौतिक मूल्य या दोनों को टुपल के रूप में रखना चुन सकते हैं।

Answer 2

कुछ विस्तार से मैं अक्का-उपयोगकर्ता समूह से प्राप्त करने में सक्षम हो सकता है

https://groups.google.com/forum/#!topic/akka-user/Ofnx_XzWrTU