singyeong v0.4.14

Singyeong.Producer (singyeong v0.4.14) View Source

Link to this section Summary

Functions

handle_call(arg1, from, arg2)

Callback implementation for GenStage.handle_call/3.

handle_cast(arg1, arg2)

Callback implementation for GenStage.handle_cast/2.

handle_demand(incoming_demand, arg)

Callback implementation for GenStage.handle_demand/2.

init(atom)

Callback implementation for GenStage.init/1.

notify(event)

Sends an event and returns immediately.

start_link(_)
sync_notify(event, timeout \\ 5000)

Sends an event and returns only after the event is dispatched.

Link to this section Functions

Link to this function

handle_call(arg1, from, arg2)

View Source

Callback implementation for GenStage.handle_call/3.

Link to this function

handle_cast(arg1, arg2)

View Source

Callback implementation for GenStage.handle_cast/2.

Link to this function

handle_demand(incoming_demand, arg)

View Source

Callback implementation for GenStage.handle_demand/2.

Link to this function

init(atom)

View Source

Callback implementation for GenStage.init/1.

Link to this function

notify(event)

View Source

Sends an event and returns immediately.

Link to this function

start_link(_)

View Source
Link to this function

sync_notify(event, timeout \\ 5000)

View Source

Sends an event and returns only after the event is dispatched.