diff --git a/src/async_nif.hrl b/src/async_nif.hrl index 8eda423..4d14a3a 100644 --- a/src/async_nif.hrl +++ b/src/async_nif.hrl @@ -25,8 +25,7 @@ begin NIFRef = erlang:make_ref(), case erlang:apply(Fun, [NIFRef|Args]) of - {ok, {enqueued, QDepth}} -> - [erlang:bump_reductions(10 * QDepth) || is_integer(QDepth), QDepth > 100], + {ok, {enqueued, _QDepth}} -> receive {NIFRef, {error, shutdown}=Error} -> %% Work unit was queued, but not executed.