Skip to content

Commit 0f9f721

Browse files
committed
Add stub heartbeat method to test subscription writers
1 parent e6bd88e commit 0f9f721

File tree

2 files changed

+8
-0
lines changed

2 files changed

+8
-0
lines changed

v2/pkg/engine/resolve/event_loop_test.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -51,6 +51,10 @@ func (f *FakeSubscriptionWriter) Complete() {
5151
f.messageCountOnComplete = len(f.writtenMessages)
5252
}
5353

54+
func (f *FakeSubscriptionWriter) Heartbeat() error {
55+
return nil
56+
}
57+
5458
func (f *FakeSubscriptionWriter) Close(SubscriptionCloseKind) {
5559
f.mu.Lock()
5660
defer f.mu.Unlock()

v2/pkg/engine/resolve/resolve_test.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4777,6 +4777,10 @@ func (s *SubscriptionRecorder) Complete() {
47774777
s.complete.Store(true)
47784778
}
47794779

4780+
func (s *SubscriptionRecorder) Heartbeat() error {
4781+
return nil
4782+
}
4783+
47804784
func (s *SubscriptionRecorder) Close(_ SubscriptionCloseKind) {
47814785
s.closed.Store(true)
47824786
}

0 commit comments

Comments
 (0)