|
|
@ -2,6 +2,7 @@ package graphvent
|
|
|
|
|
|
|
|
|
|
|
|
import (
|
|
|
|
import (
|
|
|
|
"testing"
|
|
|
|
"testing"
|
|
|
|
|
|
|
|
"time"
|
|
|
|
)
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
|
|
func TestGQLThread(t * testing.T) {
|
|
|
|
func TestGQLThread(t * testing.T) {
|
|
|
@ -15,6 +16,11 @@ func TestGQLThread(t * testing.T) {
|
|
|
|
err = LinkThreads(ctx, gql_thread, test_thread, nil)
|
|
|
|
err = LinkThreads(ctx, gql_thread, test_thread, nil)
|
|
|
|
fatalErr(t, err)
|
|
|
|
fatalErr(t, err)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
go func(thread Thread){
|
|
|
|
|
|
|
|
time.Sleep(10*time.Millisecond)
|
|
|
|
|
|
|
|
SendUpdate(ctx, thread, CancelSignal(nil))
|
|
|
|
|
|
|
|
}(gql_thread)
|
|
|
|
|
|
|
|
|
|
|
|
err = RunThread(ctx, gql_thread)
|
|
|
|
err = RunThread(ctx, gql_thread)
|
|
|
|
fatalErr(t, err)
|
|
|
|
fatalErr(t, err)
|
|
|
|
}
|
|
|
|
}
|
|
|
|