diff options
Diffstat (limited to 'internal/processing/streaming')
| -rw-r--r-- | internal/processing/streaming/streamdelete.go | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/internal/processing/streaming/streamdelete.go b/internal/processing/streaming/streamdelete.go index c9c099b46..3d4efb7a7 100644 --- a/internal/processing/streaming/streamdelete.go +++ b/internal/processing/streaming/streamdelete.go @@ -31,7 +31,12 @@ func (p *processor) StreamDelete(statusID string) error { // get all account IDs with open streams accountIDs := []string{} p.streamMap.Range(func(k interface{}, _ interface{}) bool { - accountIDs = append(accountIDs, k.(string)) + key, ok := k.(string) + if !ok { + panic("streamMap key was not a string (account id)") + } + + accountIDs = append(accountIDs, key) return true }) |