to squash: Add types to worker_throttle.

This breaks dialyzer on Erlang 17.

master/src/worker_throttle.erl

@@ -2,9 +2,12 @@
 -export([init/0, handle/1]).
 
 -define(MAX_EVENTS_PER_SECOND, 5).
+
+-include("common_types.hrl").
+
 -define(MICROSECONDS_IN_SECOND, 1000000).
 
--opaque state() :: queue().
+-opaque state() :: disco_queue(non_neg_integer()).
 -type throttle() :: {ok, non_neg_integer(), state()} | {error, term()}.
 
 -export_type([state/0]).
@@ -25,7 +28,7 @@ handle(Q) ->
         throttle(Q1, queue:len(Q1))
     end.
 
--spec throttle(queue(), non_neg_integer()) -> throttle().
+-spec throttle(disco_queue(non_neg_integer()), non_neg_integer()) -> throttle().
 throttle(_Q, N) when N >= ?MAX_EVENTS_PER_SECOND * 2 ->
     {error, ["Worker is behaving badly: Sent ",
              integer_to_list(N), " events in a second, ignoring replies."]};