diff options
| author | Evgeny Khramtsov <ekhramtsov@process-one.net> | 2019-06-28 22:16:29 +0300 |
|---|---|---|
| committer | Evgeny Khramtsov <ekhramtsov@process-one.net> | 2019-06-28 22:16:29 +0300 |
| commit | a2a061c1c8d78adea4e33b1a38187fc4226a9190 (patch) | |
| tree | 3c077fdfb9c4a677fcd02dcc19b96a48dfab7589 /src/mod_stream_mgmt.erl | |
| parent | Use yconf validator for custom Mnesia schemas (diff) | |
Avoid using broad p1_queue:queue() type wherever possible
Diffstat (limited to 'src/mod_stream_mgmt.erl')
| -rw-r--r-- | src/mod_stream_mgmt.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/mod_stream_mgmt.erl b/src/mod_stream_mgmt.erl index 09af0c7cf..c151807ff 100644 --- a/src/mod_stream_mgmt.erl +++ b/src/mod_stream_mgmt.erl @@ -50,6 +50,7 @@ is_record(Pkt, sm_r)). -type state() :: ejabberd_c2s:state(). +-type queue() :: p1_queue:queue({non_neg_integer(), erlang:timestamp(), xmpp_element() | xmlel()}). -type error_reason() :: session_not_found | session_timed_out | session_is_dead | session_has_exited | session_was_killed | session_copy_timed_out | @@ -298,7 +299,7 @@ set_resume_timeout(State, Timeout) -> State1 = restart_pending_timer(State, Timeout), State1#{mgmt_timeout => Timeout}. --spec queue_find(fun((stanza()) -> boolean()), p1_queue:queue()) +-spec queue_find(fun((stanza()) -> boolean()), queue()) -> stanza() | none. queue_find(Pred, Queue) -> case p1_queue:out(Queue) of |