Skip to content

Instantly share code, notes, and snippets.

@rambocoder

rambocoder/gen_server_consumer.erl

Forked from Licenser/gen_server_consumer.erl
Created March 22, 2012 19:41
Show Gist options
  • Save rambocoder/2162749 to your computer and use it in GitHub Desktop.
Save rambocoder/2162749 to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. @Licenser Licenser created this gist Mar 15, 2012.
    9 changes: 9 additions & 0 deletions gen_server_consumer.erl
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,9 @@
    process(Data) ->
    gen_server:cast(?SERVER, {process, Data});

    ...

    handle_cast({process, Data}, {}) ->
    do_some_funky_stuff(Data),
    reader:pop(self);
    {ok, {}}
    29 changes: 29 additions & 0 deletions gen_server_queu.erl
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,29 @@
    pop(Reader) ->
    gen_server:cast(?SERVER, {pop, Reader});

    push(Data) ->
    gen_server:cast(?SERVER, {push, Data});

    ...

    handle_cast({pop, Reader}, {[], Readers}) ->
    {ok, {[], [Reader | Readers]}};

    handle_cast({pop, Reader}, {[Data | R], []}) ->
    consumer:process(Reader, Data),
    {ok, {R, []}};


    handle_cast({pop, Reader}, {[Data | R], [First | Rdrs]}) ->
    consumer:process(First, Data),
    {ok, {R, [Reader | Rdrs]}};

    handle_cast({push, Data}, {Dates, []}) ->
    {ok, {[Data| Dates], []}};

    handle_cast({push, Data}, {[], [First | Rdrs]}) ->
    consumer:process(First, Data),
    {ok, {[], Rdrs}};