diff --git a/cmd/webrtc/webrtc.go b/cmd/webrtc/webrtc.go
index 394460de..1aa04b3a 100644
--- a/cmd/webrtc/webrtc.go
+++ b/cmd/webrtc/webrtc.go
@@ -68,7 +68,7 @@ var NewPConn func() (*pion.PeerConnection, error)
 
 func asyncHandler(tr *api.Transport, msg *api.Message) error {
 	src := tr.Request.URL.Query().Get("src")
-	stream := streams.Get(src)
+	stream := streams.GetOrNew(src)
 	if stream == nil {
 		return errors.New(api.StreamNotFound)
 	}