|
4e5343d14d
|
handle case where host is not given
|
2025-03-26 16:14:21 +01:00 |
|
|
e5dbf22676
|
re-use bsread.Source docstring for BSCache
|
2025-02-11 21:05:42 +01:00 |
|
|
90b55ef277
|
use None (bsread.source default) if channels are empty
|
2025-02-11 13:06:44 +01:00 |
|
|
38b5def8f9
|
missing not
|
2025-02-11 12:15:31 +01:00 |
|
|
153fdb754e
|
only check channel availability if using the dispatcher, i.e., if there is no host configured
|
2025-02-11 11:57:57 +01:00 |
|
|
ab2a77e4d7
|
pass through all kwargs from BSCache to bsread.source
|
2025-02-11 11:48:34 +01:00 |
|
|
047a0c2478
|
clean up
|
2023-06-08 17:10:25 +02:00 |
|
|
598705ed74
|
added clear_vars
|
2023-06-08 16:13:42 +02:00 |
|
|
776884ce35
|
added rem_var and rem_vars
|
2023-06-07 20:34:02 +02:00 |
|
|
e1aef2dc82
|
unified starting by checking all (instead of new) channels vs. received channels
|
2023-06-07 20:01:41 +02:00 |
|
|
36cf0d9724
|
added FIXED_CHANNELS constant
|
2023-06-06 11:32:22 +02:00 |
|
|
ea8c8dabaf
|
split the cases for better messages
|
2023-06-03 13:38:15 +02:00 |
|
|
c6138b4b73
|
added option the create several channels at once
|
2023-06-03 13:12:30 +02:00 |
|
|
e51ab1428c
|
added flush
|
2023-06-01 20:13:05 +02:00 |
|
|
2c66613b88
|
added a timeout counter, also as fake channel
|
2023-06-01 17:38:16 +02:00 |
|
|
89446f0c56
|
allow to set timeout and maxsize; fixed a weird conditional
|
2023-06-01 16:35:50 +02:00 |
|
|
cc4fc3268a
|
added Queue subclass where put_nowait honors mutex lock, and that can be flushed
|
2023-06-01 13:59:58 +02:00 |
|
|
bab3232c82
|
added __repr__ for everything
|
2021-09-10 14:39:51 +02:00 |
|
|
b6d5b33746
|
removed unused obj
|
2021-09-09 14:31:04 +02:00 |
|
|
718c59b3c5
|
simplified repack() logic
|
2021-09-09 14:16:57 +02:00 |
|
|
78591549a9
|
made BSCache.run() a generator; moved dealing with the queue completely into ProdThread; allowed setting the maxsize of the queue from ProdThread()
|
2021-09-08 18:41:27 +02:00 |
|
|
f8cd002cb0
|
added package structure
|
2021-09-08 14:04:00 +02:00 |
|