From 9fc3d91a17521a2858bbfb71c81dc8bda4e59775 Mon Sep 17 00:00:00 2001
From: Sergey Krashevich <svk@svk.su>
Date: Tue, 19 Mar 2024 09:46:56 +0300
Subject: [PATCH] fix(streams): handle non-string elements in slice source for
 NewStream

---
 internal/streams/stream.go | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/internal/streams/stream.go b/internal/streams/stream.go
index 75b855b8..0a8108e2 100644
--- a/internal/streams/stream.go
+++ b/internal/streams/stream.go
@@ -22,8 +22,13 @@ func NewStream(source any) *Stream {
 		}
 	case []any:
 		s := new(Stream)
-		for _, source := range source {
-			s.producers = append(s.producers, NewProducer(source.(string)))
+		for _, src := range source {
+			str, ok := src.(string)
+			if !ok {
+				log.Error().Msgf("[stream] NewStream: Expected string, got %v", src)
+				continue
+			}
+			s.producers = append(s.producers, NewProducer(str))
 		}
 		return s
 	case map[string]any: