ProducerQueue.Producer (producer_queue v5.0.2) View Source

A simple implementation of a GenStage producer

Link to this section Summary

Functions

handle_demand(new, state)

Callback implementation for GenStage.handle_demand/2.

handle_info(atom, state)

Callback implementation for GenStage.handle_info/2.

Callback implementation for GenStage.init/1.

start_link(opts \\ [])

Start a ProducerQueue.Producer linked to a ProducerQueue.Queue

Link to this section Functions

handle_demand(new, state)

Callback implementation for GenStage.handle_demand/2.

handle_info(atom, state)

Callback implementation for GenStage.handle_info/2.

init(opts)

Callback implementation for GenStage.init/1.

start_link(opts \\ [])

Start a ProducerQueue.Producer linked to a ProducerQueue.Queue