File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -332,7 +332,10 @@ async def invoke_on_restore_callbacks():
332
332
333
333
# Run the on_restored function after the flush cycle completes and
334
334
# information is sent to the client.
335
- @session .on_flushed
335
+ # Update: Using `on_flush` to have the callbacks populate the output message
336
+ # queue going to the browser. If `on_flushed` is used, the messages stall
337
+ # until the next `on_flushed` invocation.
338
+ @session .on_flush
336
339
async def invoke_on_restored_callbacks ():
337
340
print ("Trying on restored" )
338
341
if self ._on_restored_callbacks .count () == 0 :
Original file line number Diff line number Diff line change @@ -665,9 +665,6 @@ def verify_state(expected_state: ConnectionState) -> None:
665
665
with session_context (self ):
666
666
self .app .server (self .input , self .output , self )
667
667
668
- if self .bookmark .store != "disable" :
669
- await reactive_flush () # TODO: Barret; Why isn't the reactive flush triggering itself?
670
-
671
668
elif message_obj ["method" ] == "update" :
672
669
verify_state (ConnectionState .Running )
673
670
You can’t perform that action at this time.
0 commit comments