View Source OPQ.RateLimiter (OPQ: One Pooled Queue v4.0.4)

Provides rate limit.

Summary

Functions

handle_events(events, from, arg)

Callback implementation for GenStage.handle_events/3.

handle_info(arg, state)

Callback implementation for GenStage.handle_info/2.

handle_subscribe(atom, opts, from, state)

Callback implementation for GenStage.handle_subscribe/4.

init(opts)

Callback implementation for GenStage.init/1.

start_link(opts)

Functions

handle_events(events, from, arg)

Callback implementation for GenStage.handle_events/3.

handle_info(arg, state)

Callback implementation for GenStage.handle_info/2.

handle_subscribe(atom, opts, from, state)

Callback implementation for GenStage.handle_subscribe/4.

init(opts)

Callback implementation for GenStage.init/1.

start_link(opts)