ElixirのGenStageに入門する#2 バックプレッシャーを理解する - Qiita
（この記事は、「Elixir or Phoenix Advent Calendar 2017」の10日目です） 前日は@tuchiroさんのElixirでSI開発入門 #2 Ectoで楽観的ロック でした。 本掲載はElixirのGenStageに入門する#1の続きです。 前回は:producer, :producer_consumer, :consumer の三段階のステージで整数カウンターのストリーム処理を行いました。 バックプレッシャー (1背圧) さて、前回:producerのところで、handle_demandというコールバックが登場したのを覚えてらっしゃいますでしょうか？ 生産者なのに需要がトリガーとなっています。 つまり、GenStageは需要トリガーを元にストリームイベントを処理するライブラリなのです。需要トリガーで供給を引っ張ることを、ストリーム界隈(?)ではバックプレッ
Closures: Elixir vs. Ruby vs. JavaScript
Posted on 2015-06-14 Closures: Elixir vs. Ruby vs. JavaScript Closures are not the same across languages. Learn how they differ between Ruby, JavaScript and Elixir to avoid bugs and confusion. tl;dr Closures in Elixir prevent nasty side-effects. Closures in JavaScript are the worst of the three (suprirse, surprise!). Ruby is slightly better thanks to functional elements in the language, but not pe
Function currying in Elixir • Patrik Storm
Curry? # Currying is a technique that translates a function of arity N into a sequence of functions that all have the arity 1. Function arity means the number of arguments a function takes. # The add function has the arity of 2 add = fn x, y -> x + y end The term curry/currying was coined back in the 60s referring to the logician Haskell Curry. The programming language named after him has curried
Experimental.GenStage.Flow – gen_stage v0.4.1
gen_stage v0.4.1 Experimental.GenStage.Flow Computational flows with stages. GenStage.Flow allows developers to express computations on collections, similar to the Enum and Stream modules, although computations will be executed in parallel using multiple GenStage s. Flow was also designed to work with both bounded (finite) and unbounded (infinite) data. Allowing the data to be partitioned into arb
Task – Elixir v1.1.1
Elixir v1.1.1 Task Conveniences for spawning and awaiting for tasks. Tasks are processes meant to execute one particular action throughout their life-cycle, often with little or no communication with other processes. The most common use case for tasks is to compute a value asynchronously: task = Task.async(fn -> do_some_work() end) res = do_some_other_work() res + Task.await(task) Tasks spawned wi
[翻訳] Elixirのストリーム - Qiita
Drew Olsonさんの2015年6月8日付のブログ記事Elixir Streamsの翻訳です。 Elixir言語のマニュアルにはストリームについて、"Any enumerable that generates items one by one during enumeration is called a stream."「列挙できるもの～うまい訳がないのでEnumerableってみんなそのまま言ってますね。「列挙値」と訳してるものもあるけど～のうち列挙している最中に項目を一つ一つ生成できるものはストリームと呼ばれる」とあります。 他の言語だと「遅延評価できる無限リスト」とでも言えばいいのかな。たいてい「普通に書くとこうですが遅延評価を使うとこういうこともできます」と教科書的な例が出てるだけで終わっちゃうんですがこの記事には面白い利用例があったので紹介します。 私見ですがErlangのi
![[翻訳] Elixirのストリーム - Qiita](https://cdn-ak-scissors.b.st-hatena.com/image/square/8e88ab595d7d67e2038008353d8c5f8035811a7b/height=288;version=1;width=512/https%3A%2F%2Fqiita-user-contents.imgix.net%2Fhttps%253A%252F%252Fqiita-user-contents.imgix.net%252Fhttps%25253A%25252F%25252Fcdn.qiita.com%25252Fassets%25252Fpublic%25252Farticle-ogp-background-afbab5eb44e0b055cce1258705637a91.png%253Fixlib%253Drb-4.0.0%2526w%253D1200%2526blend64%253DaHR0cHM6Ly9xaWl0YS11c2VyLXByb2ZpbGUtaW1hZ2VzLmltZ2l4Lm5ldC9odHRwcyUzQSUyRiUyRnFpaXRhLWltYWdlLXN0b3JlLnMzLmFtYXpvbmF3cy5jb20lMkYwJTJGNDYyOTQlMkZwcm9maWxlLWltYWdlcyUyRjE0NzM2OTA2MDQ_aXhsaWI9cmItNC4wLjAmYXI9MSUzQTEmZml0PWNyb3AmbWFzaz1lbGxpcHNlJmZtPXBuZzMyJnM9MWJhNWUxNDYxYjc2YmY1ZDljNjk1N2ZjODgzYWYyMWI%2526blend-x%253D120%2526blend-y%253D467%2526blend-w%253D82%2526blend-h%253D82%2526blend-mode%253Dnormal%2526s%253D5cf4494b1aea3d39f9584eb91b1f937a%3Fixlib%3Drb-4.0.0%26w%3D1200%26fm%3Djpg%26mark64%3DaHR0cHM6Ly9xaWl0YS11c2VyLWNvbnRlbnRzLmltZ2l4Lm5ldC9-dGV4dD9peGxpYj1yYi00LjAuMCZ3PTk2MCZoPTMyNCZ0eHQ9JTVCJUU3JUJGJUJCJUU4JUE4JUIzJTVEJTIwRWxpeGlyJUUzJTgxJUFFJUUzJTgyJUI5JUUzJTgzJTg4JUUzJTgzJUFBJUUzJTgzJUJDJUUzJTgzJUEwJnR4dC1hbGlnbj1sZWZ0JTJDdG9wJnR4dC1jb2xvcj0lMjMxRTIxMjEmdHh0LWZvbnQ9SGlyYWdpbm8lMjBTYW5zJTIwVzYmdHh0LXNpemU9NTYmdHh0LXBhZD0wJnM9NzVlMjdkNjk5NjJiZDZkNGNjMzViMzBiMjdkZTI3ZTk%26mark-x%3D120%26mark-y%3D112%26blend64%3DaHR0cHM6Ly9xaWl0YS11c2VyLWNvbnRlbnRzLmltZ2l4Lm5ldC9-dGV4dD9peGxpYj1yYi00LjAuMCZ3PTgzOCZoPTU4JnR4dD0lNDBIaXJvZnVtaVRhbW9yaSZ0eHQtY29sb3I9JTIzMUUyMTIxJnR4dC1mb250PUhpcmFnaW5vJTIwU2FucyUyMFc2JnR4dC1zaXplPTM2JnR4dC1wYWQ9MCZzPTQzNTBiNTY1NDI5Zjc4NDE2Mzc5ODJhNmEzZjRhYzk2%26blend-x%3D242%26blend-y%3D480%26blend-w%3D838%26blend-h%3D46%26blend-fit%3Dcrop%26blend-crop%3Dleft%252Cbottom%26blend-mode%3Dnormal%26s%3Dc64613eab239079f1f9cfad2a2f41cb5)
Elixir Tasks vs Scala Futures
Elixir has introduced a wonderful first class concept called a Task. It allows you to do some work in a new process and easily collect the result, like so: iex(1)> something = Task.async fn -> ...(1)> 10 + 6 ...(1)> end %Task{pid: #PID<0.44.0>, ref: #Reference<0.0.0.55>} iex(2)> Task.await(something) 16 On first glance, it looks a lot like constructs found in other languages. For example, Scala ha
1
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
Follow-up: Function currying in Elixir
High score video games
High score video games
Benjamin Tan's Learnings & Writings - How to build Streams in Elixir easily with Stream.resource/3 Awesomeness