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

A GenStage producer that feeds items in a buffered queue to the consumers.

Summary

Functions

handle_call(atom, from, state)

Callback implementation for GenStage.handle_call/3.

handle_cast(arg1, state)

Callback implementation for GenStage.handle_cast/2.

handle_demand(demand, arg)

Callback implementation for GenStage.handle_demand/2.

init(atom)

Callback implementation for GenStage.init/1.

start_link(name)

Functions

handle_call(atom, from, state)

Callback implementation for GenStage.handle_call/3.

handle_cast(arg1, state)

Callback implementation for GenStage.handle_cast/2.

handle_demand(demand, arg)

Callback implementation for GenStage.handle_demand/2.

init(atom)

Callback implementation for GenStage.init/1.

start_link(name)