MCPcopy Index your code
hub / github.com/bugy/script-server / wait_buffer_flush

Method wait_buffer_flush

src/tests/observable_test.py:888–889  ·  view source on GitHub ↗
(buffered_observable)

Source from the content-addressed store, hash-verified

886
887 @staticmethod
888 def wait_buffer_flush(buffered_observable):
889 time.sleep(buffered_observable.period_millis * 1.3 / 1000.0 + 0.01)

Callers 15

test_time_buffer_single_updateMethod · 0.95
test_slow_time_buffer_single_updateMethod · 0.95
test_time_buffer_aggregate_single_updateMethod · 0.95
test_time_buffer_multiple_updatesMethod · 0.95
test_time_buffer_aggregate_multiple_updatesMethod · 0.95
test_time_buffer_aggregate_multiple_observers_multiple_updatesMethod · 0.95
test_time_buffer_push_before_late_subscriptionMethod · 0.95
test_time_buffer_aggregated_push_after_late_subscriptionMethod · 0.95
test_replay_time_buffer_aggregated_push_after_late_subscriptionMethod · 0.95
test_time_buffer_closeMethod · 0.95
test_time_buffer_close_late_subscriptionMethod · 0.95
test_time_buffer_multiple_buffersMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected