mirror of
https://forgejo.ellis.link/continuwuation/continuwuity.git
synced 2025-09-11 21:13:02 +02:00
Compare commits
4 commits
83a97e63d2
...
db2e7690c8
Author | SHA1 | Date | |
---|---|---|---|
|
db2e7690c8 | ||
|
1f1cde297d | ||
|
2e80200c64 | ||
|
9e8c193840 |
2 changed files with 2 additions and 1 deletions
|
@ -6,6 +6,7 @@ use conduwuit::{
|
||||||
trace,
|
trace,
|
||||||
utils::stream::{BroadbandExt, ReadyExt},
|
utils::stream::{BroadbandExt, ReadyExt},
|
||||||
warn,
|
warn,
|
||||||
|
info
|
||||||
};
|
};
|
||||||
use futures::{FutureExt, StreamExt, future::ready};
|
use futures::{FutureExt, StreamExt, future::ready};
|
||||||
use ruma::{CanonicalJsonValue, RoomId, ServerName, events::StateEventType};
|
use ruma::{CanonicalJsonValue, RoomId, ServerName, events::StateEventType};
|
||||||
|
|
|
@ -42,7 +42,7 @@ pub async fn create_hash_and_sign_event(
|
||||||
let prev_events: Vec<OwnedEventId> = self
|
let prev_events: Vec<OwnedEventId> = self
|
||||||
.services
|
.services
|
||||||
.state
|
.state
|
||||||
.get_forward_extremities(room_id)
|
.get_forward_extremities(room_id, _mutex_lock)
|
||||||
.take(20)
|
.take(20)
|
||||||
.map(Into::into)
|
.map(Into::into)
|
||||||
.collect()
|
.collect()
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue