dragonsinth · December 17, 2021 12:28
diff --git a/eventstream_iterator.go b/eventstream_iterator.go
 for it := eventStream.Subscribe().Iterator(); true; {
 	v, err := it.Next(ctx)
 	if err == eventstream.ErrDone {
 		return nil
 	} else if err != nil {
 		return err
 	}
 	msg := v.(bwamp.Event)
 	// [Send msg to client]
 }
	for it := eventStream.Subscribe().Iterator(); true; {
	v, err := it.Next(ctx)
	if err == eventstream.ErrDone {
	return nil
	} else if err != nil {
	return err
	}
	msg := v.(bwamp.Event)
	// [Send msg to client]
	}