Closed BrianJKoopman closed 5 years ago
The processing of subscription messages was blocking the main reactor. This patch moves the operations to a separate thread by calling them via threads.deferToThread().
threads.deferToThread()
resolves #41
The processing of subscription messages was blocking the main reactor. This patch moves the operations to a separate thread by calling them via
threads.deferToThread()
.resolves #41