|
|
@ -728,7 +728,8 @@ func GQLSubscribeFn(p graphql.ResolveParams, fn func(GraphSignal, graphql.Resolv
|
|
|
|
c := make(chan interface{})
|
|
|
|
c := make(chan interface{})
|
|
|
|
go func(c chan interface{}, server *GQLThread) {
|
|
|
|
go func(c chan interface{}, server *GQLThread) {
|
|
|
|
ctx.Log.Logf("gqlws", "GQL_SUBSCRIBE_THREAD_START")
|
|
|
|
ctx.Log.Logf("gqlws", "GQL_SUBSCRIBE_THREAD_START")
|
|
|
|
sig_c := server.UpdateChannel(0)
|
|
|
|
sig_c := server.UpdateChannel(1)
|
|
|
|
|
|
|
|
sig_c <- nil
|
|
|
|
for {
|
|
|
|
for {
|
|
|
|
val, ok := <- sig_c
|
|
|
|
val, ok := <- sig_c
|
|
|
|
if ok == false {
|
|
|
|
if ok == false {
|
|
|
|