diff --git a/jupyter_bokeh/widgets.py b/jupyter_bokeh/widgets.py
index 1b15a49..8b1100d 100644
--- a/jupyter_bokeh/widgets.py
+++ b/jupyter_bokeh/widgets.py
@@ -151,15 +151,15 @@ def _sync_model(self, _model: BokehModel, content: dict[str, Any], _buffers: lis
             for cb in model._callbacks.get(attr, []):
                 cb(attr, old, new)
         elif kind == "ColumnsStreamed":
-            model = content["model"]
-            data = content["data"]
-            rollover = content["rollover"]
+            model = event["model"]
+            data = event["data"]
+            rollover = event["rollover"]
 
             assert isinstance(model, ColumnDataSource)
             model._stream(data, rollover, setter=setter)
         elif kind == "ColumnsPatched":
-            model = content["model"]
-            patches = content["data"]
+            model = event["model"]
+            patches = event["patches"]
 
             assert isinstance(model, ColumnDataSource)
             model.patch(patches, setter=setter)