aboutsummaryrefslogtreecommitdiff
path: root/aoc2023/build/packages/gleam_otp/src/gleam@otp@task.erl
diff options
context:
space:
mode:
Diffstat (limited to 'aoc2023/build/packages/gleam_otp/src/gleam@otp@task.erl')
-rw-r--r--aoc2023/build/packages/gleam_otp/src/gleam@otp@task.erl111
1 files changed, 0 insertions, 111 deletions
diff --git a/aoc2023/build/packages/gleam_otp/src/gleam@otp@task.erl b/aoc2023/build/packages/gleam_otp/src/gleam@otp@task.erl
deleted file mode 100644
index e004284..0000000
--- a/aoc2023/build/packages/gleam_otp/src/gleam@otp@task.erl
+++ /dev/null
@@ -1,111 +0,0 @@
--module(gleam@otp@task).
--compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function]).
-
--export([async/1, try_await/2, await/2, try_await_forever/1, await_forever/1]).
--export_type([task/1, await_error/0, message/1]).
-
--opaque task(FWJ) :: {task,
- gleam@erlang@process:pid_(),
- gleam@erlang@process:pid_(),
- gleam@erlang@process:process_monitor(),
- gleam@erlang@process:selector(message(FWJ))}.
-
--type await_error() :: timeout | {exit, gleam@dynamic:dynamic_()}.
-
--type message(FWK) :: {from_monitor, gleam@erlang@process:process_down()} |
- {from_subject, FWK}.
-
--spec async(fun(() -> FWL)) -> task(FWL).
-async(Work) ->
- Owner = erlang:self(),
- Subject = gleam@erlang@process:new_subject(),
- Pid = gleam@erlang@process:start(
- fun() -> gleam@erlang@process:send(Subject, Work()) end,
- true
- ),
- Monitor = gleam@erlang@process:monitor_process(Pid),
- Selector = begin
- _pipe = gleam_erlang_ffi:new_selector(),
- _pipe@1 = gleam@erlang@process:selecting_process_down(
- _pipe,
- Monitor,
- fun(Field@0) -> {from_monitor, Field@0} end
- ),
- gleam@erlang@process:selecting(
- _pipe@1,
- Subject,
- fun(Field@0) -> {from_subject, Field@0} end
- )
- end,
- {task, Owner, Pid, Monitor, Selector}.
-
--spec assert_owner(task(any())) -> nil.
-assert_owner(Task) ->
- Self = erlang:self(),
- case erlang:element(2, Task) =:= Self of
- true ->
- nil;
-
- false ->
- gleam@erlang@process:send_abnormal_exit(
- Self,
- <<"awaited on a task that does not belong to this process"/utf8>>
- )
- end.
-
--spec try_await(task(FWP), integer()) -> {ok, FWP} | {error, await_error()}.
-try_await(Task, Timeout) ->
- assert_owner(Task),
- case gleam_erlang_ffi:select(erlang:element(5, Task), Timeout) of
- {ok, {from_subject, X}} ->
- gleam_erlang_ffi:demonitor(erlang:element(4, Task)),
- {ok, X};
-
- {ok, {from_monitor, {process_down, _, Reason}}} ->
- {error, {exit, Reason}};
-
- {error, nil} ->
- {error, timeout}
- end.
-
--spec await(task(FWT), integer()) -> FWT.
-await(Task, Timeout) ->
- _assert_subject = try_await(Task, Timeout),
- {ok, Value} = case _assert_subject of
- {ok, _} -> _assert_subject;
- _assert_fail ->
- erlang:error(#{gleam_error => let_assert,
- message => <<"Assertion pattern match failed"/utf8>>,
- value => _assert_fail,
- module => <<"gleam/otp/task"/utf8>>,
- function => <<"await"/utf8>>,
- line => 117})
- end,
- Value.
-
--spec try_await_forever(task(FWV)) -> {ok, FWV} | {error, await_error()}.
-try_await_forever(Task) ->
- assert_owner(Task),
- case gleam_erlang_ffi:select(erlang:element(5, Task)) of
- {from_subject, X} ->
- gleam_erlang_ffi:demonitor(erlang:element(4, Task)),
- {ok, X};
-
- {from_monitor, {process_down, _, Reason}} ->
- {error, {exit, Reason}}
- end.
-
--spec await_forever(task(FWZ)) -> FWZ.
-await_forever(Task) ->
- _assert_subject = try_await_forever(Task),
- {ok, Value} = case _assert_subject of
- {ok, _} -> _assert_subject;
- _assert_fail ->
- erlang:error(#{gleam_error => let_assert,
- message => <<"Assertion pattern match failed"/utf8>>,
- value => _assert_fail,
- module => <<"gleam/otp/task"/utf8>>,
- function => <<"await_forever"/utf8>>,
- line => 149})
- end,
- Value.