From 8c5bffc98f0d01862d7e34794268e37d64ec1158 Mon Sep 17 00:00:00 2001 From: Tim Voronov Date: Sat, 30 Jul 2022 17:05:03 -0400 Subject: [PATCH] Fixed tests --- pkg/runtime/expressions/event_wait_test.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/pkg/runtime/expressions/event_wait_test.go b/pkg/runtime/expressions/event_wait_test.go index 6c57ae25..e82f9c39 100644 --- a/pkg/runtime/expressions/event_wait_test.go +++ b/pkg/runtime/expressions/event_wait_test.go @@ -106,21 +106,21 @@ func (m *MockedObservable) Emit(ctx context.Context, eventName string, args core } func (m *MockedObservable) Subscribe(_ context.Context, sub events.Subscription) (events.Stream, error) { - calls, found := m.Args[sub.EventName] + calls, found := m.Args[sub.EventName.String()] if !found { calls = make([]*values.Object, 0, 10) - m.Args[sub.EventName] = calls + m.Args[sub.EventName.String()] = calls } - es, found := m.subscribers[sub.EventName] + es, found := m.subscribers[sub.EventName.String()] if !found { es = NewMockedEventStream(make(chan events.Message)) - m.subscribers[sub.EventName] = es + m.subscribers[sub.EventName.String()] = es } - m.Args[sub.EventName] = append(calls, sub.Options) + m.Args[sub.EventName.String()] = append(calls, sub.Options) return es, nil }