Packages
absinthe
1.2.5
1.11.0
1.10.2
1.10.1
1.10.0
1.9.1
1.9.0
1.8.0
1.7.11
1.7.10
1.7.9
1.7.8
1.7.7
1.7.6
1.7.5
1.7.4
1.7.3
1.7.2
1.7.1
1.7.0
1.6.8
1.6.7
retired
1.6.6
1.6.5
1.6.4
1.6.3
1.6.2
1.6.1
1.6.0
1.6.0-rc.1
1.6.0-rc.0
1.5.5
1.5.4
1.5.3
1.5.2
1.5.1
1.5.0
1.5.0-rc.5
1.5.0-rc.4
1.5.0-rc.3
1.5.0-rc.2
1.5.0-rc.1
1.5.0-rc.0
1.5.0-beta.2
1.5.0-beta.1
1.5.0-beta.0
1.5.0-alpha.4
1.5.0-alpha.3
1.5.0-alpha.2
1.5.0-alpha.1
1.5.0-alpha.0
1.4.16
1.4.15
1.4.14
1.4.13
1.4.12
1.4.11
1.4.10
1.4.9
1.4.8
retired
1.4.7
1.4.6
1.4.5
1.4.4
1.4.3
1.4.2
1.4.1
1.4.0
1.4.0-rc.3
1.4.0-rc.2
1.4.0-rc.1
1.4.0-rc.0
1.4.0-beta.5
1.4.0-beta.4
1.4.0-beta.3
1.4.0-beta.2
1.4.0-beta.1
1.3.2
1.3.1
1.3.0
1.3.0-rc.0
1.3.0-beta.2
1.3.0-beta.1
1.3.0-beta.0
1.2.6
1.2.5
1.2.4
1.2.3
1.2.2
1.2.1
1.2.0
1.2.0-rc.0
1.2.0-beta.0
1.2.0-alpha0
1.2.0-alpha.2
1.2.0-alpha.1
1.1.11
1.1.10
1.1.9
1.1.8
1.1.7
1.1.6
1.1.5
1.1.4
1.1.3
1.1.2
1.1.1
1.1.0
1.0.0
0.5.2
0.5.1
0.5.0
0.4.6
0.4.5
0.4.4
0.4.3
0.4.2
0.4.1
0.4.0
0.2.3
0.2.2
0.2.1
0.1.0
GraphQL for Elixir
Security advisory:
This version has known vulnerabilities.
View advisories
Current section
Files
Jump to
Current section
Files
lib/absinthe/resolution/plugin/async.ex
defmodule Absinthe.Resolution.Plugin.Async do
@moduledoc """
This plugin enables asynchronous execution of a field.
See also `Absinthe.Resolution.Helpers.async/1`
# Example Usage:
Using the `Absinthe.Resolution.Helpers.async/1` helper function:
```elixir
field :time_consuming, :thing do
resolve fn _, _, _ ->
async(fn ->
{:ok, long_time_consuming_function()}
end)
end
end
```
Using the bare plugin API
```elixir
field :time_consuming, :thing do
resolve fn _, _, _ ->
task = Task.async(fn ->
{:ok, long_time_consuming_function()}
end
{:plugin, #{__MODULE__}, task}
end
end
```
This module also serves as an example for how to build a basic resolution plugin.
See the source code and associated comments for further details.
"""
@behaviour Absinthe.Resolution.Plugin
# We must set the flag to false because if a previous resolution iteration
# set it to true it needs to go back to false now. It will be set
# back to true if any field uses this plugin again.
def before_resolution(acc) do
Map.put(acc, __MODULE__, false)
end
# A field has used this plugin, we need to set our flag on the accumulator true
def init(task, acc) do
{task, Map.put(acc, __MODULE__, true)}
end
# Nothing to do after resolution for this plugin, so we no-op
def after_resolution(acc), do: acc
# If the flag is set we need to do another resolution phase.
# otherwise, we do not
def pipeline(pipeline, acc) do
case acc do
%{__MODULE__ => true} ->
[Absinthe.Phase.Document.Execution.Resolution | pipeline]
_ ->
pipeline
end
end
# In a later resolution phase we've now come across an invocation of this plugin
# left behind by a prior phase. It needs to be resolved to a real value now.
def resolve({task, opts}, acc) do
{Task.await(task, Keyword.get(opts, :timeout, 30_000)), acc}
end
end