Merge branch 'fix-timeout' into ap07
This commit is contained in:
commit
c57f36ccca
@ -157,7 +157,7 @@ where
|
|||||||
.build()
|
.build()
|
||||||
.expect("Error while initializing tokio runtime for federation");
|
.expect("Error while initializing tokio runtime for federation");
|
||||||
rt.block_on(async {
|
rt.block_on(async {
|
||||||
let capacity = 50;
|
let capacity = 6;
|
||||||
let (tx, rx) = flume::bounded::<RequestBuilder>(capacity);
|
let (tx, rx) = flume::bounded::<RequestBuilder>(capacity);
|
||||||
let mut handles = Vec::with_capacity(capacity);
|
let mut handles = Vec::with_capacity(capacity);
|
||||||
for _ in 0..capacity {
|
for _ in 0..capacity {
|
||||||
|
Loading…
Reference in New Issue
Block a user