akka-stream

6गर्मी

1उत्तर

द्वारा धारा विभाजित मैं निम्नलिखित सरल मामले वर्ग पदानुक्रम है: sealed trait Message case class Foo(bar: Int) extends Message case class Baz(qux: String) extends Message और मैं एक Flow[Message, Me

8गर्मी

1उत्तर

अक्का स्ट्रीम: स्रोत [आउट, मैट]

में मैट का प्रतिनिधित्व करता है अक्का धाराओं में स्रोत [आउट, मैट] या सिंक [इन, मैट] में मैट क्या दर्शाता है। वास्तव में इसका उपयोग कब किया जाएगा?

5गर्मी

1उत्तर

भविष्य के साथ निकलने वाले स्रोत से कैसे निपटें [टी]?

चलो कहते हैं कि मैं कुछ इटरेटर करते हैं: val nextElemIter: Iterator[Future[Int]] = Iterator.continually(...) और मुझे लगता है कि पुनरावर्तक से एक स्रोत का निर्माण करना चाहते: val source: Source[Futur

5गर्मी

1उत्तर

अक्का-http में क्वेरी पैरामीटर कैसे पढ़ा जाए?

मुझे प्रसंस्करण अनुरोध करते समय कक्षा के प्रकार के लिए अक्का-http पुस्तकालय मार्शल और अनारशल पता है। लेकिन अब, मुझे GET अनुरोध के अनुरोध-पैरामीटर पढ़ने की आवश्यकता है। मैंने parameter() विधि की कोशिश

6गर्मी

1उत्तर

कैसे एक एक अक्का स्ट्रीम के प्रवाह को एक और धारा के आधार पर

कहो को नियंत्रित करता है कि मैं दो स्रोतों है: val ticks = Source(1 to 10) val values = Source[Int](Seq(3,4,4,7,8,8,8,8,9).to[collection.immutable.Iterable]) मैं अक्का स्ट्रीम में एक Graph[...] प्र

6गर्मी

1उत्तर

एक अक्का धारा

के अंदर भविष्य से बैकप्रेसर बनाएं, मैं सामान्य रूप से अक्का धाराओं और धाराओं में नया हूं इसलिए मैंने एक वैचारिक स्तर पर पूरी तरह से गलत समझा होगा, लेकिन क्या भविष्य में हल होने तक मैं बैकप्रेसर बना सक

15गर्मी

2उत्तर

अक्का स्ट्रीम

में अभिनेता से प्रवाह बनाना क्रमशः Source.actorPublisher() और Sink.actorSubscriber() विधियों का उपयोग करके अभिनेताओं से स्रोत और सिंक बनाना संभव है। लेकिन क्या अभिनेता से Flow बनाना संभव है? वैचारिक इ

7गर्मी

1उत्तर

अक्का स्ट्रीम - ग्राफ

में एक सहायक सिंक के भौतिक मूल्य को कैसे रखा जाए मेरे पास Flow लौटने वाला फ़ंक्शन है जिसका तर्क ग्राफ के कुछ तत्वों को एक पैरामीटर के रूप में पारित सहायक Sink पर पास करना शामिल है। मैं सहायक Sink के भ

6गर्मी

3उत्तर

स्प्लिट अक्का स्ट्रीम स्रोत दो

में मेरे पास एक अक्का स्ट्रीम Source है जो मैं एक अनुमान के अनुसार दो स्रोतों में विभाजित करना चाहता हूं। उदा। होने एक स्रोत (प्रकार जानबूझकर सरलीकृत कर रहे हैं): val source: Source[Either[Throwable,

6गर्मी

1उत्तर

स्ट्रीम

में चेन अक्का-http-क्लाइंट अनुरोध, मैं स्ट्रीम के रूप में अक्का-http-क्लाइंट का उपयोग कर http अनुरोध को चेन करना चाहता हूं। एक श्रृंखला में प्रत्येक http अनुरोध पिछले अनुरोधों की सफलता/प्रतिक्रिया पर