the_end v1.1.0 TheEnd.RequestDrainer

This module’s process waits pending requests to finish when terminating itself.

So, your should put this module’s spec after your Endpoint’s one and before AcceptTanceStopper’s one

children = [
  # ... other specs
  {TheEnd.RequestDrainer,
    [endpoint: MyApp.Endpoint, gatherer: TheEnd.ListenerGatherer.Plug, timeout: 10_000]},
  {TheEnd.AcceptanceStopper,
    [endpoint: MyApp.Endpoint, gatherer: TheEnd.ListenerGatherer.Plug]}
]

Initialization:

:endpoint - endpoint module
:gatherer - module that implements TheEnd.ListenerGatherer behaviour
:timeout - max limit of time you can wait for requests to finish (milliseconds)

See Also

Link to this section Summary

Functions

start_link(opts)

Link to this section Functions

start_link(opts)