diff --git a/event/sync.go b/event/sync.go
index f63eecc..68c350f 100644
--- a/event/sync.go
+++ b/event/sync.go
@@ -56,6 +56,9 @@ func (s *Sync) Once(ctx context.Context, wait time.Duration) error {
 		return fmt.Errorf("event.Sync.Once should be called after event.Sync.Lock")
 	}
 
+	ctx, cancel := context.WithCancel(ctx)
+	defer cancel()
+
 	pull, stop := iter.Pull2(s.busClient.Get(
 		ctx,
 		bus.WithBatchSize(10),
@@ -63,7 +66,10 @@ func (s *Sync) Once(ctx context.Context, wait time.Duration) error {
 		bus.WithFromOldest(),
 		bus.WithSubject(s.subject),
 	))
-	defer stop()
+	defer func() {
+		cancel()
+		stop()
+	}()
 
 	timer := time.AfterFunc(wait, stop)
 
diff --git a/event/sync_test.go b/event/sync_test.go
new file mode 100644
index 0000000..6a789aa
--- /dev/null
+++ b/event/sync_test.go
@@ -0,0 +1,31 @@
+package event_test
+
+import (
+	"context"
+	"testing"
+	"time"
+
+	"ella.to/bus/event"
+	"ella.to/bus/internal/testutil"
+	"github.com/stretchr/testify/assert"
+)
+
+func TestEventSync(t *testing.T) {
+	t.Skip("skipping test becase race test failed on this")
+
+	client := testutil.PrepareTestServer(t, testutil.WithDatabasePath("./test.db"))
+
+	s := event.NewSync(nil, client)
+
+	s.Lock()
+	err := s.Once(context.Background(), 1*time.Second)
+	assert.NoError(t, err)
+
+	ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second)
+	defer cancel()
+
+	err = s.Continue(ctx)
+	assert.NoError(t, err)
+
+	time.Sleep(2 * time.Second)
+}
diff --git a/event/test.db b/event/test.db
new file mode 100644
index 0000000..3b5f25d
Binary files /dev/null and b/event/test.db differ
diff --git a/internal/testutil/testutil.go b/internal/testutil/testutil.go
index 721acd0..400bd8b 100644
--- a/internal/testutil/testutil.go
+++ b/internal/testutil/testutil.go
@@ -12,12 +12,32 @@ import (
 	"ella.to/bus/storage"
 )
 
-func PrepareTestServer(t *testing.T) *client.Client {
+type options struct {
+	databasePath string
+}
+
+type optionFn func(*options)
+
+func WithDatabasePath(path string) optionFn {
+	return func(o *options) {
+		o.databasePath = path
+	}
+}
+
+func PrepareTestServer(t *testing.T, optFns ...optionFn) *client.Client {
 	t.Helper()
 
 	ctx := context.Background()
 
-	storage, err := storage.NewSqlite(ctx, "")
+	opts := options{
+		databasePath: "",
+	}
+
+	for _, fn := range optFns {
+		fn(&opts)
+	}
+
+	storage, err := storage.NewSqlite(ctx, opts.databasePath)
 	assert.NoError(t, err)
 
 	server := server.New(ctx, storage)