@@ -62,16 +62,16 @@ def awareness(self) -> Awareness:
6262
6363 def _receive (self , msg ):
6464 message = bytes (msg ["buffers" ][0 ])
65- mtype = message [0 ]
66- if mtype == YMessageType .SYNC :
67- reply = handle_sync_message (message [1 :], self ._ydoc )
68- if reply is not None :
69- self ._comm .send (buffers = [reply ])
70- if message [1 ] == YSyncMessageType .SYNC_STEP2 :
71- self ._ydoc .observe (self ._send )
72- elif mtype == YMessageType .AWARENESS :
73- payload = read_message (message [1 :])
74- self ._awareness .apply_awareness_update (payload , None )
65+ match message [0 ]:
66+ case YMessageType .SYNC :
67+ reply = handle_sync_message (message [1 :], self ._ydoc )
68+ if reply is not None :
69+ self ._comm .send (buffers = [reply ])
70+ if message [1 ] == YSyncMessageType .SYNC_STEP2 :
71+ self ._ydoc .observe (self ._send )
72+ case YMessageType .AWARENESS :
73+ payload = read_message (message [1 :])
74+ self ._awareness .apply_awareness_update (payload , None )
7575
7676 def _send (self , event : TransactionEvent ):
7777 update = event .update
@@ -116,13 +116,13 @@ def unobserve_awareness(self, subscription_id: str) -> None:
116116 def _repr_mimebundle_ (self , * args , ** kwargs ): # pragma: nocover
117117 plaintext = repr (self )
118118 if len (plaintext ) > 110 :
119- plaintext = plaintext [:110 ] + '…'
119+ plaintext = plaintext [:110 ] + "…"
120120 data = {
121121 "text/plain" : plaintext ,
122122 "application/vnd.jupyter.ywidget-view+json" : {
123123 "version_major" : 2 ,
124124 "version_minor" : 0 ,
125125 "model_id" : self ._comm .comm_id ,
126- }
126+ },
127127 }
128128 return data
0 commit comments