Skip to content

Commit 2a99b35

Browse files
Updated GroupedDataSubscriber example to report feedback messages through subscriber callbacks
1 parent de7e83b commit 2a99b35

File tree

1 file changed

+2
-2
lines changed
  • examples/groupeddatasubscribe

1 file changed

+2
-2
lines changed

examples/groupeddatasubscribe/main.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -401,10 +401,10 @@ def process_data(subscriber: GroupedDataSubscriber, timestamp: np.uint64, data_b
401401

402402
average_frequency = frequency_sum / frequency_count
403403

404-
print(f"\nAverage frequency for {frequency_count:,} values in second {Ticks.to_datetime(timestamp).second}: {average_frequency:.6f} Hz")
404+
subscriber.statusmessage(f"\nAverage frequency for {frequency_count:,} values in second {Ticks.to_datetime(timestamp).second}: {average_frequency:.6f} Hz")
405405

406406
if subscriber.downsampled_count > 0:
407-
print(f" Downsampled {subscriber.downsampled_count:,} measurements in last measurement set...")
407+
subscriber.statusmessage(f" Downsampled {subscriber.downsampled_count:,} measurements in last measurement set...")
408408
subscriber.downsampled_count = 0
409409

410410
if __name__ == "__main__":

0 commit comments

Comments
 (0)