Packages
A project that aims to fuse the concurrency models of OTP and Javascript to allow the careful user to write concurrent code that runs on both the otp backend and the gleam backend
Retired package: This is fundamentally broken, a new version will be published soon
Current section
Files
Jump to
Current section
Files
src/fused@internal@queue.erl
-module(fused@internal@queue).
-compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function, nowarn_nomatch, inline]).
-define(FILEPATH, "src/fused/internal/queue.gleam").
-export([new/0, push/2, pop/1]).
-export_type([queue/1]).
-if(?OTP_RELEASE >= 27).
-define(MODULEDOC(Str), -moduledoc(Str)).
-define(DOC(Str), -doc(Str)).
-else.
-define(MODULEDOC(Str), -compile([])).
-define(DOC(Str), -compile([])).
-endif.
?MODULEDOC(false).
-opaque queue(FYT) :: {queue, list(FYT), list(FYT)}.
-file("src/fused/internal/queue.gleam", 7).
?DOC(false).
-spec new() -> queue(any()).
new() ->
{queue, [], []}.
-file("src/fused/internal/queue.gleam", 11).
?DOC(false).
-spec push(queue(FYW), FYW) -> queue(FYW).
push(Queue, X) ->
{queue, Push, Pop} = Queue,
Push@1 = [X | Push],
{queue, Push@1, Pop}.
-file("src/fused/internal/queue.gleam", 17).
?DOC(false).
-spec pop(queue(FYZ)) -> {ok, {FYZ, queue(FYZ)}} | {error, nil}.
pop(Queue) ->
case Queue of
{queue, [X], []} ->
{ok, {X, {queue, [], []}}};
{queue, Push, [X@1 | Pop]} ->
{ok, {X@1, {queue, Push, Pop}}};
{queue, [], []} ->
{error, nil};
{queue, Push@1, []} ->
_pipe = {queue, [], lists:reverse(Push@1)},
pop(_pipe)
end.