Minor test and example enhancements for composite processor (#36)

* Minor test and example enhancements for composite processor
* Minor update for session timeout

Author: Tim Middleton

examples/events/cache/people_listen/main.go

@@ -14,6 +14,7 @@ import (
 	"fmt"
 	"github.com/oracle/coherence-go-client/coherence"
 	"log"
+	"os"
 	"time"
 )
 
@@ -39,6 +40,13 @@ func main() {
 
 	defer session.Close()
 
+	session.AddSessionLifecycleListener(
+		coherence.NewSessionLifecycleListener().
+			OnClosed(func(event coherence.SessionLifecycleEvent) {
+				log.Println("session closed, exiting")
+				os.Exit(0)
+			}))
+
 	// create a new NamedMap of Person with key int
 	namedMap, err := coherence.GetNamedMap[int, Person](session, "people")
 	if err != nil {

examples/processors/main.go

@@ -67,11 +67,14 @@ func main() {
 	}
 	fmt.Println("Person is", *person)
 
+	var updated *bool
 	// update the age to 68
-	if _, err = coherence.Invoke[int, Person, bool](ctx, namedMap, 1, processors.Update("age", 68)); err != nil {
+	if updated, err = coherence.Invoke[int, Person, bool](ctx, namedMap, 1, processors.Update("age", 68)); err != nil {
 		panic(err)
 	}
 
+	fmt.Println("Updated = ", *updated)
+
 	// get the Person
 	person, err = namedMap.Get(ctx, 1)
 	if err != nil {
@@ -116,4 +119,16 @@ func main() {
 			fmt.Println("Person is", se.Value)
 		}
 	}
+
+	// updating multiple values using composite processors to update person one age to 67 and un-retire them.
+	// this will return an array of booleans to indicate each update
+	var proc = processors.Update("age", 67).AndThen(processors.Update("retired", false))
+
+	type result [2]bool
+	var updated2 *result
+	updated2, err = coherence.Invoke[int, Person, result](ctx, namedMap, 1, proc)
+	if err != nil {
+		panic(err)
+	}
+	fmt.Println("Boolean updates are", updated2[0], updated2[0])
 }

test/e2e/standalone/processor_test.go

@@ -422,6 +422,22 @@ func RunTestInvokeUpdater(t *testing.T, namedMap coherence.NamedMap[int, Person]
 	g.Expect(err).ShouldNot(gomega.HaveOccurred())
 	g.Expect(result).To(gomega.Not(gomega.BeNil()))
 	g.Expect(result.Age).To(gomega.Equal(20))
+
+	// invoke multiple processors
+	type result2 [2]bool
+	var updated *result2
+	proc := processors.Update("age", 22).AndThen(processors.Update("name", "James Brown"))
+	updated, err = coherence.Invoke[int, Person, result2](ctx, namedMap, 1, proc)
+	g.Expect(err).ShouldNot(gomega.HaveOccurred())
+	g.Expect(len(updated)).To(gomega.Equal(2))
+	g.Expect(updated[0]).To(gomega.Equal(true))
+	g.Expect(updated[1]).To(gomega.Equal(true))
+
+	result, err = namedMap.Get(ctx, 1)
+	g.Expect(err).ShouldNot(gomega.HaveOccurred())
+	g.Expect(result).To(gomega.Not(gomega.BeNil()))
+	g.Expect(result.Age).To(gomega.Equal(22))
+	g.Expect(result.Name).To(gomega.Equal("James Brown"))
 }
 
 func RunTestInvokeConditionalPutAll(t *testing.T, namedMap coherence.NamedMap[int, Person]) {