diff --git a/syncapi/consumers/roomserver.go b/syncapi/consumers/roomserver.go
index 6379c5f69..404f28b9c 100644
--- a/syncapi/consumers/roomserver.go
+++ b/syncapi/consumers/roomserver.go
@@ -170,7 +170,7 @@ func (s *OutputRoomEventConsumer) onNewRoomEvent(
 	}
 
 	if pduPos, err = s.notifyJoinedPeeks(ctx, &ev, pduPos); err != nil {
-		logrus.WithError(err).Panicf("Failed to notifyJoinedPeeks for PDU pos %d", pduPos)
+		logrus.WithError(err).Errorf("Failed to notifyJoinedPeeks for PDU pos %d", pduPos)
 		return err
 	}
 
diff --git a/syncapi/sync/provider.go b/syncapi/sync/provider.go
new file mode 100644
index 000000000..fd8bfe03d
--- /dev/null
+++ b/syncapi/sync/provider.go
@@ -0,0 +1,11 @@
+package sync
+
+import "github.com/matrix-org/dendrite/syncapi/types"
+
+type SyncProvider interface {
+	WaitFor()
+}
+
+type SyncStream interface {
+	GetLatestPosition() types.StreamPosition
+}