I hereby claim:
- I am aspett on github.
- I am aspett (https://keybase.io/aspett) on keybase.
- I have a public key ASDylFnJDuhnLPupQgFxOzll1YTjOomS_Kdg6b6mbPvwkAo
To claim this, I am signing this object:
| def start_link(_opts) do | |
| Broadway.start_link(__MODULE__, | |
| name: BroadwayPipeline, | |
| producer: [ | |
| module: {Producer, []}, | |
| concurrency: 1, | |
| rate_limiting: [allowed_messages: 11, interval: 1000] # 11/s is just over 950k / day | |
| ], | |
| processors: [ | |
| default: [concurrency: 5] |
| defmodule Producer do | |
| use GenStage | |
| @behaviour Broadway.Producer | |
| def init(_opts) do | |
| {:producer, 0} | |
| end | |
| def handle_demand(demand, stored_demand) do |
| defmodule BlockingBuffer do | |
| @moduledoc """ | |
| A process which holds a queue and blocks when the length of the queue | |
| exceeds a predefined number (100) | |
| """ | |
| use GenServer | |
| @max_buffer 100 # Tweak as required, or move into opts |
| defmodule BroadwayPipeline do | |
| use Broadway | |
| def start_link(_opts) do | |
| Broadway.start_link(__MODULE__, | |
| name: BroadwayPipeline, | |
| producer: [ | |
| module: {Producer, []}, | |
| concurrency: 1, | |
| ], |
I hereby claim:
To claim this, I am signing this object:
| <?xml version="1.0"?> | |
| <root> | |
| <item> | |
| <name>TMUX Key Remappings</name> | |
| <item> | |
| <name>TMUX: Right Control to Ctrl+B</name> | |
| <identifier>private.right_control_to_control_b</identifier> | |
| <autogen> | |
| --KeyToKey-- | |
| KeyCode::CONTROL_R, |