Remove duplicate error checking (#59)

Author: Tim Middleton

coherence/common.go

@@ -452,12 +452,6 @@ func executeGetAll[K comparable, V any](ctx context.Context, bc *baseClient[K, V
 				return
 			}
 
-			if err1 != nil {
-				ch <- &StreamedEntry[K, V]{Err: err1}
-				close(ch)
-				return
-			}
-
 			// deserialize key and value
 			if key, err1 = bc.keySerializer.Deserialize(response.Key); err1 != nil {
 				ch <- &StreamedEntry[K, V]{Err: err1}
@@ -1187,12 +1181,6 @@ func executeEntrySetFilter[K comparable, V any](ctx context.Context, bc *baseCli
 				return
 			}
 
-			if err1 != nil {
-				ch <- &StreamedEntry[K, V]{Err: err1}
-				close(ch)
-				return
-			}
-
 			// deserialize key and value
 			if key, err1 = bc.keySerializer.Deserialize(response.Key); err1 != nil {
 				ch <- &StreamedEntry[K, V]{Err: err1}

examples/events/cache/people_listen/main.go

@@ -14,7 +14,6 @@ import (
 	"fmt"
 	"github.com/oracle/coherence-go-client/coherence"
 	"log"
-	"os"
 	"time"
 )
 
@@ -40,13 +39,6 @@ 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 {