7 files changed, 25 insertions(+), 32 deletions(-)

M apps/bed/src/bed.app.src
M apps/bed/src/bed_app.erl
M apps/bed/src/bed_io_srv.erl
M apps/bed/src/bed_sofo_pool.erl
M apps/bed/src/bed_sofo_worker.erl
M apps/bed/src/bed_sup.erl
M rebar.config

@@ 1,15 1,1 @@
-{application, bed,
- [{description, "An OTP application"},
-  {vsn, "0.1.0"},
-  {registered, []},
-  {mod, {bed_app, []}},
-  {applications,
-   [kernel,
-    stdlib
-   ]},
-  {env,[]},
-  {modules, []},
-
-  {licenses, ["Apache 2.0"]},
-  {links, []}
- ]}.
+{ application , bed , [ { description , "An OTP application" } , { vsn , "0.1.0" } , { registered , [ ] } , { mod , { bed_app , [ ] } } , { applications , [ kernel , stdlib ] } , { env , [ ] } , { modules , [ ] } , { licenses , [ "Apache 2.0" ] } , { links , [ ] } ] } .

@@ 7,7 7,8 @@
 
 -behaviour(application).
 
--export([start/2, stop/1]).
+-export([start/2,
+         stop/1]).
 
 start(_StartType, _StartArgs) ->
     bed_sup:start_link().

@@ 3,20 3,25 @@
 -behaviour(gen_server).
 
 -export([start_link/0]).
--export([init/1, handle_call/3, handle_cast/2]).
+-export([init/1,
+         handle_call/3,
+         handle_cast/2]).
 -export([receive_worker_list_change/2]).
 
 -record(state,
-        {sofo_pool_pids = sets:from_list([]) :: sets:set(pid()), chunk_inbox = [] :: [binary()]}).
+        {sofo_pool_pids = sets:from_list([]) :: sets:set(pid()),
+         chunk_inbox = [] :: [binary()]}).
 
 start_link() ->
     gen_server:start_link({local, ?MODULE}, ?MODULE, [], []).
 
 init(_) ->
-    bed_sofo_pool:subscribe_to_worker_list_changes_via({?MODULE, receive_worker_list_change}),
+    bed_sofo_pool:notify_worker_list_changes_via({?MODULE,
+                                                  receive_worker_list_change}),
     {ok, #state{}}.
 
--spec receive_worker_list_change(Event :: enter | leave, Pids :: sets:set(pid())) ->
+-spec receive_worker_list_change(Event :: enter | leave,
+                                 Pids :: sets:set(pid())) ->
                                     term().
 receive_worker_list_change(Event, Pids) ->
     gen_server:call(?MODULE, {receive_worker_list_change, {Event, Pids}}).

@@ 1,9 1,9 @@
 -module(bed_sofo_pool).
 
--export([subscribe_to_worker_list_changes_via/1]).
+-export([notify_worker_list_changes_via/1]).
 
--spec subscribe_to_worker_list_changes_via({atom(), atom()}) -> 'ok' | {'error', atom()}.
-subscribe_to_worker_list_changes_via({Module, Function}) ->
+-spec notify_worker_list_changes_via({atom(), atom()}) -> ok | {error, atom()}.
+notify_worker_list_changes_via({Module, Function}) ->
     {error, undefined};
-subscribe_to_worker_list_changes_via(_) ->
+notify_worker_list_changes_via(_) ->
     {error, badarg}.

@@ 1,1 1,1 @@
--module(bed_sofo_worker).>
\ No newline at end of file
+-module(bed_sofo_worker).

@@ 76,7 76,8 @@ fan_bytes(BitsPerRule, Workers, FH) ->
                    FH :: file:io_device()) ->
                       {error, undefined}.
 fan_bytes_do(BytesToFanOut, Workers, FH) ->
-    io:format("Fanning out ~p bytes.~nFrom: ~p~nTo: ~p~n", [BytesToFanOut, Workers, FH]),
+    io:format("Fanning out ~p bytes.~nFrom: ~p~nTo: ~p~n",
+              [BytesToFanOut, Workers, FH]),
     {error, undefined}.
 
 write_src(FileName, IOListSrc) ->


@@ 93,7 94,9 @@ main_fan() ->
 
 main() ->
     Program =
-        [<<"-module(local).">>, <<"-export([main/0]).">>, <<"main() -> io:format(\"hi?\").">>],
+        [<<"-module(local).">>,
+         <<"-export([main/0]).">>,
+         <<"main() -> io:format(\"hi?\").">>],
     FileName = "local.erl",
     StrModuleName = "local",
     write_src(FileName, Program),

@@ 2,12 2,10 @@
 
 { deps , [ ] } .
 
-{ relx , [
-  { release , { bed , "0.1.0" } , [ bed , sasl ] } ,
-  { mode , dev } , { sys_config , "./config/sys.config" } ,
-  { vm_args , "./config/vm.args" }
-] } .
+{ relx , [ { release , { bed , "0.1.0" } , [ bed , sasl ] } , { mode , dev } , { sys_config , "./config/sys.config" } , { vm_args , "./config/vm.args" } ] } .
 
 { profiles , [ { prod , [ { relx , [ { mode , prod } ] } ] } ] } .
 
 { plugins , [ rebar3_format ] } .
+
+{ format , [ { files , [ "rebar.config" , "apps/bed/src/*.erl" , "apps/bed/src/*.app.src" ] } , { formatter , default_formatter } , { options , #{ paper => 80 , inline_attributes => none , inline_fields => none , inline_items => none } } ] } .