[B! Akka Stream] surumedakaã®ãƒ–ãƒƒã‚¯ãƒžãƒ¼ã‚¯

surumedaka id:surumedaka

Akka Streamã«é–¢ã™ã‚‹surumedakaã®ãƒ–ãƒƒã‚¯ãƒžãƒ¼ã‚¯ (5)

${{author_name}}$

{{{comment_expanded}}}

{{label}}

{{#is_bookmark}}ãƒªã‚¹ãƒˆ{{/is_bookmark}}{{^is_bookmark}}ãƒªãƒ³ã‚¯{{/is_bookmark}}

${{author_name}}$
{{author_name}}{{created}}
{{ #comment }}{{ comment }}{{ /comment }}
- {{ label }}

${{author_name}}$

{{{comment_expanded}}}

{{label}}

{{#is_bookmark}}ãƒªã‚¹ãƒˆ{{/is_bookmark}}{{^is_bookmark}}ãƒªãƒ³ã‚¯{{/is_bookmark}}

Play Frameworkã§Server-Sent Events(SSE)ã‚’ä½¿ã£ã¦Server pushã™ã‚‹æ–¹æ³•ã‚ã‚Œã“ã‚Œ - FLINTERS Engineer's Blog
ã‚ã‘ã¾ã—ã¦ãŠã‚ã§ã¨ã†ã”ã–ã„ã¾ã™ã€‚ åˆã‚ã¾ã—ã¦ã€2017å¹´4æœˆã«ä¸é€”å…¥ç¤¾ã—ãŸå¼µæ²¢ã¨ç”³ã—ã¾ã™ã€‚ ä»Šå›žã¯Play Frameworkã§Server-Sent Events(SSE)ã‚’ä½¿ç”¨ã—ã¦Server pushã‚’è¡Œã†å®Ÿè£…æ–¹æ³•ã«ã¤ã„ã¦æ›¸ãã¾ã™ã€‚ WebSocketã®æƒ…å ±ã¯æ¤œç´¢ã™ã‚‹ã¨è‰²ã€…è¦‹ã¤ã‹ã‚Šã¾ã™ãŒã€SSEã®è¨˜äº‹ã‚„ã‚µãƒ³ãƒ—ãƒ«ã‚³ãƒ¼ãƒ‰ã¯ã‚ã¾ã‚Šè¦‹ã‹ã‘ãªã„ãŸã‚â€¦ã€‚ Play Framework 2.5ã‹ã‚‰streamé–¢é€£ã®APIå®Ÿè£…ãŒAkka Streamã«å¤‰ã‚ã‚Šã¾ã—ãŸã€‚ãã®ãŸã‚ã€Server pushã®APIã§ã‚‚Akka Streamã‚’ä½¿ç”¨ã™ã‚‹å¿…è¦ãŒã‚ã‚Šã¾ã™ã€‚ã“ã®è¨˜äº‹ã§ã¯SSEã§ã®Akka Streamã®ä½¿ç”¨æ–¹æ³•ã«ã¤ã„ã¦ç´¹ä»‹ã—ã¾ã™ã€‚ Server-Sent Eventsã¨ã¯ Client(ãƒ–ãƒ©ã‚¦ã‚¶)ã¸HTTP server pushã‚’å®Ÿç¾ã™ã‚‹ãŸã‚ã®æŠ€è¡“ã®1ã¤ã§ã€ä»¥ä¸‹ã®ã‚ˆã†ãªç‰¹å¾´ãŒã‚ã‚Šã¾ã™ã€‚ HTTPã‚’åˆ©
surumedaka 2018/01/10
Scala

Akka Stream

SSE
ãƒªãƒ³ã‚¯
Akka Streamã§ã‚¹ã‚¯ãƒ¬ã‚¤ãƒ”ãƒ³ã‚°æ™‚ã«ã‚µãƒ¼ãƒãƒ¼ã«æ€ã„ã‚„ã‚Šã‚’ä¸Žãˆã‚‹ - FLINTERS Engineer's Blog
ã“ã‚“ã«ã¡ã¯ã€è…é‡Žã§ã™ã€‚ è¿‘é ƒã¯Webä¸Šã§æ§˜ã€…ãªã‚µãƒ¼ãƒ“ã‚¹ãŒèª•ç”Ÿã—ã€èª°ã‚‚ãŒä¾¿åˆ©ã«ä½¿ã£ã¦ã„ã‚‹ã¨æ€ã„ã¾ã™ã€‚ã¾ãŸã€IFTTTã§ãã‚Œã‚‰ã‚’ç¹‹ã„ã ã‚Šã€ã‚¤ãƒ™ãƒ³ãƒˆã‚’LINEã«é€šçŸ¥ã—ãŸã‚Šã™ã‚‹ã®ã‚‚ç°¡å˜ã§ã™ã€‚ ãã‚Œã¯APIãŒå…¬é–‹ã•ã‚Œã¦ã„ã‚‹ã‹ã‚‰ãªã®ã§ã™ãŒã€ãƒ‡ãƒ¼ã‚¿ãŒã»ã—ã„ã‘ã©APIãŒå…¬é–‹ã•ã‚Œã¦ã„ãªã„å ´åˆã¯ã‚¹ã‚¯ãƒ¬ã‚¤ãƒ”ãƒ³ã‚°ã§è‡ªåŠ›ã§ãƒ‡ãƒ¼ã‚¿ã‚’å–ã£ã¦ãã‚‹ã—ã‹ã‚ã‚Šã¾ã›ã‚“ã€‚ äººåŠ›ã§ã¯ãªãã¦ãƒ—ãƒã‚°ãƒ©ãƒ ã§Webã‚µã‚¤ãƒˆã«ã‚¢ã‚¯ã‚»ã‚¹ã™ã‚‹ã¨ãã¯ã€æ°—ã‚’ã¤ã‘ãªã„ã¨ã‚¹ã‚¯ãƒ¬ã‚¤ãƒ”ãƒ³ã‚°å…ˆã®ã‚µãƒ¼ãƒãƒ¼ã«æ€ã‚ã¬è² è·ã‚’ã‹ã‘ã¦ã—ã¾ã†ã‹ã‚‚çŸ¥ã‚Œã¾ã›ã‚“ã€‚ æ—©æœã«è‡ªå®…ã«è¦å¯ŸãŒæŠ¼ã—å¯„ã›ã¦ãã¦é€®æ•ã•ã‚Œã¦ã—ã¾ã†ã®ã¯é¿ã‘ãŸã„ã®ã§ã€ã‚µãƒ¼ãƒã‚’ã„ãŸã‚ã‚‹ã‚ˆã†ã«ã‚¹ã‚¯ãƒ¬ã‚¤ãƒ”ãƒ³ã‚°ã—ãŸã„ã¨æ€ã„ã¾ã™ã€‚ Throttleã§æµé‡åˆ¶é™ ã¨ã„ã†è¨³ã§Akka Streamã§ã•ãã£ã¨ä½œã‚ŠãŸã„ã¨æ€ã„ã¾ã™ã€‚ ã›ã£ã‹ããªã®ã§HTTPã‚¯ãƒ©ã‚¤ã‚¢ãƒ³ãƒˆã¯Akka HTTPã‚’ä½¿ã„ã¾ã™ã€‚ ææ–™ã¯ä»¥ä¸‹ã§ã™ã€‚ä¾å˜ãƒ©ã‚¤ãƒ–ãƒ©ãƒªã«è¿½åŠ ã—ã¾
surumedaka 2017/01/16
Scala

Akka Stream

ã‚¹ã‚¯ãƒ¬ã‚¤ãƒ”ãƒ³ã‚°
ãƒªãƒ³ã‚¯
Akka Streams ã«ã¤ã„ã¦ã®åŸºç¤Žæ¦‚å¿µ - Qiita
Akka Streams ãŒ2.4ä»¥é™ã‹ã‚‰experimentalã‚’å¤–ã—ã¦ã€æ£å¼ç‰ˆã‚’ãƒªãƒªãƒ¼ã‚¹ã—ã¾ã—ãŸã€‚ä¸åº¦ä¼šç¤¾ã§3æ—¥ã®HackerDaysã‚’æ©Ÿã«ã€Akka Streams ã‚’å‹‰å¼·ã—ã¯ã˜ã‚ã¾ã—ãŸã€‚ ã“ã®è¨˜äº‹ã§ã¯ã€AkkaStreamã®å…¬å¼ãƒ‰ã‚ãƒ¥ãƒ¡ãƒ³ãƒˆã‚’æŠœç²‹ã—ã€ç¿»è¨³ã—ãªãŒã‚‰ã€AkkaStreamã®åŸºç¤Žæ¦‚å¿µã‚’èª¬æ˜Žã—ã¾ã™ã€‚ Akka Streams ã£ã¦ãªã« èƒŒæ™¯ ä»Šã®Internetä¸Šã€æˆ‘ã€…ã¯è†¨å¤§ãªãƒ‡ãƒ¼ã‚¿ã‚’æ¶ˆè²»ã—ã¦ã„ã‚‹ã€‚ãã®å¤§é‡ã®ãƒ‡ãƒ¼ã‚¿ã‚’äººã€…ã¯ãƒ“ãƒƒã‚°ãƒ‡ãƒ¼ã‚¿ã¨å‘¼ã‚“ã§ã„ã‚‹wã€‚ ã‚‚ã†æ˜”ã¿ãŸã„ã«ãƒ‡ãƒ¼ã‚¿ã‚’å…¨éƒ¨ãƒ€ã‚¦ãƒ³ãƒãƒ¼ãƒ‰ã—ã¦å‡¦ç†ã€å‡¦ç†å®Œäº†ã—ã¦ã‚¢ãƒƒãƒ—ãƒãƒ¼ãƒ‰çš„ãªå‡¦ç†ã¯æ™‚é–“æŽ›ã‹ã‚Šã™ãŽã€ãã‚‚ãã‚‚ä¸€å°ã®ã‚µãƒ¼ãƒã«ä¿å˜ã—ãã‚Œãªã„ãƒ‡ãƒ¼ã‚¿ã¯å‡¦ç†ã§ããªã„ã®ã§ã€Streamã¿ãŸã„ãªæµã‚Œã¨ã—ã¦ã®å‡¦ç†ãŒå¿…è¦ã«ãªã£ã¦ã„ã‚‹ã€‚ AkkaãŒä½¿ã†Actorãƒ¢ãƒ‡ãƒ«ã‚‚ãã®ä¸€ä¾‹ã€ãƒ‡ãƒ¼ã‚¿ã‚’åˆ†å‰²ã—ã€ãƒ¡ãƒƒã‚»ãƒ¼ã‚¸ã¨ã—ã¦Actorã«é€ã‚‹ã€Actorã¯åªã€…æµ
surumedaka 2016/11/18
Akka Stream
ãƒªãƒ³ã‚¯
Error Handling in Streams â€¢ Akka Documentation
surumedaka 2016/11/18
Akka Stream
ãƒªãƒ³ã‚¯
Akka Stream 2.4ã‹ã‚‰ã®æ–°API | XoYo24's Blog
A little Advanced Akka Streams APIå‰å›žã®éƒ¨åˆ†ã§ã€Sourceã€Flowã€Sinkã‚’ç¹‹ã„ã¦ã„ã‘ã°ã€ç·šå½¢ã®å‡¦ç†ã‚’ã‚·ãƒ³ãƒ—ãƒ«ã«å®Ÿè£…å‡ºæ¥ã‚‹ã€‚ ã§ã‚‚éžç·šå½¢ã®å‡¦ç†ã¯ã©ã†ã§ã—ã‚‡ã†ã‹ï¼Ÿ GraphAkka Streamã¯Streamã®å®Ÿè¡Œãƒˆãƒãƒã‚¸ãƒ¼ã€ã©ã†å‡¦ç†ã™ã‚‹ã®ã‚’è¡¨ã™æ¦‚å¿µã‚’Graphï¼ˆå›³ï¼‰ã¨å‘¼ã¶ã€‚ ç·šå½¢ã€éžç·šå½¢ã€åˆ†å²ã®ã‚ã‚‹ãƒ‡ãƒ¼ã‚¿å‡¦ç†ã¯å…¨éƒ¨Graphã§ã‚ã‚‹ã€‚ Junctionsã¾ãšã€éžç·šåž‹å‡¦ç†ã‚’ã™ã‚‹ãŸã‚ã€Akka StreamãŒæä¾›ã—ãŸåˆ†å²ã‚’è¦‹ã¦ã¿ã‚ˆã†ã€‚ Fan-out è¤‡æ•°å‡ºåŠ› Broadcast[T] â€“ (1 input, N outputs) inputã‚’ã™ã¹ã¦ã®outputã«å‡ºã™ã€‚ Balance[T] â€“ (1 input, N outputs) inputã‚’ä»»æ„ä¸€ã¤ã®outputã«å‡ºã™ã€‚ UnZip[A,B] â€“ (1 input, 2 outputs) Tu
surumedaka 2016/08/25
Akka Stream
ãƒªãƒ³ã‚¯
1