Electric.Shapes.Consumer.EventHandler.Subqueries.Steady (electric v1.6.2)

Copy Markdown View Source

Summary

Types

t()

Functions

drain_queue(state, effects, opts \\ [])

Types

t()

@type t() :: %Electric.Shapes.Consumer.EventHandler.Subqueries.Steady{
  queue: Electric.Shapes.Consumer.Subqueries.MoveQueue.t(),
  shape_info: Electric.Shapes.Consumer.Subqueries.ShapeInfo.t(),
  views: Electric.Shapes.Consumer.Subqueries.Views.t()
}

Functions

drain_queue(state, effects, opts \\ [])

@spec drain_queue(t(), Electric.Shapes.Consumer.EffectList.t(), keyword()) ::
  {:ok, t() | Electric.Shapes.Consumer.EventHandler.Subqueries.Buffering.t(),
   Electric.Shapes.Consumer.EffectList.t()}
  | {:error, term()}