ã€Akka】Akka StreamsãŒã‚ã£ã¡ã‚ƒä¾¿åˆ©ã™ãŽã¦è„³æ±ãŒå‡ºãŸè©±ã— | Scala Tech Blogã“ã‚“ã«ã¡ã¯ï¼Smalgoã®ä¾†ç”°ã§ã™ã€‚ 注æ„：タイトルã¯éŽæ¿€ã§ã™ãŒå†…容至ã£ã¦æ™®é€šãªãƒãƒ¥ãƒ¼ãƒˆãƒªã‚¢ãƒ«è¨˜äº‹ã§ã™ã€‚ 仕事ã§Workerを作ã£ãŸæ™‚ã«ä½¿ã£ã¦ã¿ã¦ã‚ã£ã¡ã‚ƒä¾¿åˆ©ã ã¨æ€ã£ãŸã®ã§Akka Streamsã«ã¤ã„ã¦æ›¸ããŸã„ã¨æ€ã„ã¾ã™ï¼ ã¾ã ã¾ã ä¸ã®å®Ÿè£…ã®æ·±ã„ã¨ã“ã‚ã¾ã§è¿½ãˆã¦ã‚‹ã‚ã‘ã˜ã‚ƒãªã„ã®ã§é–“é•ã£ã¦ã„ãŸã‚‰æ•™ãˆã¦ãã ã•ã„。 Akka Streamsã¨ã¯ Reactive Streams（ノンブãƒãƒƒã‚ングã§back pressureãªéžåŒæœŸã‚¹ãƒˆãƒªãƒ¼ãƒ 処ç†ã®æ¨™æº–仕様）ã®Akka実装 Back Pressureã¨ã¯ éžåŒæœŸãªã‚¹ãƒˆãƒªãƒ¼ãƒ 処ç†ã®å ´åˆä¸‹è¨˜ã®å•é¡ŒãŒèµ·ãã‚‹ Publisherå´ã®å‡¦ç†ãŒæ—©ã„å ´åˆSubscriberå´ã®ãƒãƒƒãƒ•ã‚¡ãƒ¼ãŒæº¢ã‚Œã¦ã—ã¾ã† Subscriberã«é æ…®ã—ã¦Publisherå´ã®å‡¦ç†ã‚’抑ãˆãŸå ´åˆã¯ç„¡é§„ãŒå¤šããªã£ã¦ã—ã¾ã† ãれをSubscriberãŒè‡ªåˆ†ãŒå‡¦ç†ã§ãã‚‹é‡ã‚’Publisherã«
{{#tags}}- {{label}}
{{/tags}}