Packages

pobox

1.1.0
1.2.0 1.1.0 1.0.4 1.0.3 1.0.2

External buffer processes to protect against mailbox overflow

Current section

Files

Jump to
Readme
5 Versions
0 Dependencies
Dependants
Files
Activity
pobox src samples pobox_queue_buf.erl
Raw

src/samples/pobox_queue_buf.erl 

-module(pobox_queue_buf).



-behaviour(pobox_buf).

%% API

-export([new/0, push/2, pop/1, drop/2, push_drop/2]).



new() ->

  queue:new().



push(Msg, Q) ->

  queue:in(Msg, Q).



pop(Q) ->

  queue:out(Q).



drop(N, Q) ->

  element(2, queue:split(N, Q)).



push_drop(Msg, Q) ->

  push(Msg, drop(1, Q)).