Updated test apps cmd/listen... to continue Listening when event fails (

#229)

added comments in db/event_ref.go

cmd/listen/main.go

@@ -81,7 +81,10 @@ func main() {
 			event, err := iter.Next()
 
 			if err != nil {
-				break
+				// Handle error here based on specific usecase
+				// We can continue Listening
+				log.Printf("%v\n", err)
+				continue // go back to beginning of for loop
 			}
 
 			fmt.Printf("client app | Ref Path: %s | event.Path %s | event.Snapshot() = %v\n", ref.Path, event.Path, event.Snapshot())

cmd/listen2/main.go

@@ -94,7 +94,10 @@ func main() {
 			event, err := iter.Next()
 
 			if err != nil {
-				break
+				// Handle error here based on specific usecase
+				// We can continue Listening
+				log.Printf("%v\n", err)
+				continue // go back to beginning of for loop
 			}
 
 			err = event.Unmarshal(&key)
@@ -136,7 +139,10 @@ func main() {
 			event, err := iter2.Next()
 
 			if err != nil {
-				break
+				// Handle error here based on specific usecase
+				// We can continue Listening
+				log.Printf("%v\n", err)
+				continue // go back to beginning of for loop
 			}
 
 			fmt.Printf("2nd Listener | Ref Path: %s | event.Path %s | event.Snapshot() = %v\n", ref2.Path, event.Path, event.Snapshot())

db/event_ref.go

@@ -38,6 +38,7 @@ func (r *Ref) Listen(ctx context.Context) (*SnapshotIterator, error) {
 
 	resp, err := r.sendListen(ctx, "GET", opts...)
 
+	// This is temporary true in case initialization fails
 	done := true
 
 	if err != nil {
@@ -50,6 +51,7 @@ func (r *Ref) Listen(ctx context.Context) (*SnapshotIterator, error) {
 		return &SnapshotIterator{done: &done}, err
 	}
 
+	// Initialization passed, we can continue with Listening
 	done = false
 	go r.startListeningWithReconnect(ctx, opts, resp, &done, sseDataChan)