Skip to content

Commit a5e8ebd

Browse files
author
Tim Middleton
committed
Fixup v0 regression
1 parent 42fc88b commit a5e8ebd

File tree

2 files changed

+5
-6
lines changed

2 files changed

+5
-6
lines changed

coherence/event.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -662,6 +662,7 @@ func makeGeneralListenerGroup[K comparable, V any](manager *mapEventManager[K, V
662662
// for a key listener.
663663
func makeKeyListenerGroup[K comparable, V any](manager *mapEventManager[K, V], key K) (*listenerGroup[K, V], error) {
664664
group := makeGeneralListenerGroup(manager)
665+
group.request = manager.newSubscribeRequest("key")
665666

666667
serializedKey, err := manager.serializer.Serialize(key)
667668
if err != nil {

test/v1/base/base_test.go

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -58,13 +58,12 @@ func TestGetAndPutRequests(t *testing.T) {
5858
_ = ensureCache(g, session, cache)
5959

6060
// create key and value
61-
key := ensureSerializedInt32(g, 32)
6261
value := ensureSerializedString(g, "value")
62+
key := ensureSerializedInt32(g, 32)
6363

6464
// clear the cache
6565
err = coherence.TestClearCache(ctx, session, cache)
6666
g.Expect(err).Should(gomega.BeNil())
67-
6867
assertSize(g, session, cache, 0)
6968

7069
// test get with no value in the cache
@@ -86,6 +85,7 @@ func TestGetAndPutRequests(t *testing.T) {
8685
currentValue, err = coherence.TestGet(ctx, session, cache, key)
8786
g.Expect(err).Should(gomega.BeNil())
8887
g.Expect(currentValue).ShouldNot(gomega.BeNil())
88+
8989
getValue, err = serializerString.Deserialize(*currentValue)
9090
g.Expect(err).Should(gomega.BeNil())
9191
g.Expect(*getValue).Should(gomega.Equal("value"))
@@ -340,6 +340,8 @@ func TestReplace(t *testing.T) {
340340
g = gomega.NewWithT(t)
341341
ctx = context.Background()
342342
cache = "test-replace"
343+
key = ensureSerializedInt32(g, 1)
344+
value = ensureSerializedString(g, "value")
343345
err error
344346
currentValue *[]byte
345347
getValue *string
@@ -350,10 +352,6 @@ func TestReplace(t *testing.T) {
350352

351353
_ = ensureCache(g, session, cache)
352354

353-
// create key and value
354-
key := ensureSerializedInt32(g, 1)
355-
value := ensureSerializedString(g, "value")
356-
357355
// clear the cache
358356
err = coherence.TestClearCache(ctx, session, cache)
359357
g.Expect(err).Should(gomega.BeNil())

0 commit comments

Comments
 (0)