aboutsummaryrefslogtreecommitdiffstats
path: root/vendor/github.com/vektah/gqlgen/graphql/defer.go
diff options
context:
space:
mode:
authorMichael Muré <batolettre@gmail.com>2018-07-29 18:11:33 +0200
committerMichael Muré <batolettre@gmail.com>2018-07-29 18:51:56 +0200
commit6363518c85cbd8247a5f6507b8a1dd3903cfb71d (patch)
treeaa51652e9881196b3637247988cbd5155f42b5e2 /vendor/github.com/vektah/gqlgen/graphql/defer.go
parentff2fd14e3f10a7206d4ec86f07e524cfa290e0fc (diff)
downloadgit-bug-6363518c85cbd8247a5f6507b8a1dd3903cfb71d.tar.gz
relay connection working with gqlgen
Diffstat (limited to 'vendor/github.com/vektah/gqlgen/graphql/defer.go')
-rw-r--r--vendor/github.com/vektah/gqlgen/graphql/defer.go30
1 files changed, 30 insertions, 0 deletions
diff --git a/vendor/github.com/vektah/gqlgen/graphql/defer.go b/vendor/github.com/vektah/gqlgen/graphql/defer.go
new file mode 100644
index 00000000..79346a84
--- /dev/null
+++ b/vendor/github.com/vektah/gqlgen/graphql/defer.go
@@ -0,0 +1,30 @@
+package graphql
+
+import (
+ "io"
+ "sync"
+)
+
+// Defer will begin executing the given function and immediately return a result that will block until the function completes
+func Defer(f func() Marshaler) Marshaler {
+ var deferred deferred
+ deferred.mu.Lock()
+
+ go func() {
+ deferred.result = f()
+ deferred.mu.Unlock()
+ }()
+
+ return &deferred
+}
+
+type deferred struct {
+ result Marshaler
+ mu sync.Mutex
+}
+
+func (d *deferred) MarshalGQL(w io.Writer) {
+ d.mu.Lock()
+ d.result.MarshalGQL(w)
+ d.mu.Unlock()
+}