fix rtsSession initial state
This commit is contained in:
@@ -232,9 +232,6 @@ describe("createHomeserverConnected$ - Grace Period", () => {
|
|||||||
GRACE_PERIOD,
|
GRACE_PERIOD,
|
||||||
);
|
);
|
||||||
|
|
||||||
session.setMembershipStatus(Status.Connected);
|
|
||||||
session.setProbablyLeft(false);
|
|
||||||
|
|
||||||
// Initial state: Everything is connected
|
// Initial state: Everything is connected
|
||||||
expect(hsConnected.combined$.value).toBe(true);
|
expect(hsConnected.combined$.value).toBe(true);
|
||||||
|
|
||||||
@@ -259,9 +256,6 @@ describe("createHomeserverConnected$ - Grace Period", () => {
|
|||||||
GRACE_PERIOD,
|
GRACE_PERIOD,
|
||||||
);
|
);
|
||||||
|
|
||||||
session.setMembershipStatus(Status.Connected);
|
|
||||||
session.setProbablyLeft(false);
|
|
||||||
|
|
||||||
// Initial state: Connected
|
// Initial state: Connected
|
||||||
expect(hsConnected.combined$.value).toBe(true);
|
expect(hsConnected.combined$.value).toBe(true);
|
||||||
|
|
||||||
@@ -287,9 +281,6 @@ describe("createHomeserverConnected$ - Grace Period", () => {
|
|||||||
GRACE_PERIOD,
|
GRACE_PERIOD,
|
||||||
);
|
);
|
||||||
|
|
||||||
session.setMembershipStatus(Status.Connected);
|
|
||||||
session.setProbablyLeft(false);
|
|
||||||
|
|
||||||
// 1. Initial error: wait until it flips to false
|
// 1. Initial error: wait until it flips to false
|
||||||
client.setSyncState(SyncState.Error);
|
client.setSyncState(SyncState.Error);
|
||||||
expect(hsConnected.combined$.value).toBe(true);
|
expect(hsConnected.combined$.value).toBe(true);
|
||||||
|
|||||||
@@ -85,7 +85,7 @@ export function createHomeserverConnected$(
|
|||||||
fromEvent(matrixRTCSession, MembershipManagerEvent.StatusChanged).pipe(
|
fromEvent(matrixRTCSession, MembershipManagerEvent.StatusChanged).pipe(
|
||||||
map(() => matrixRTCSession.membershipStatus ?? Status.Unknown),
|
map(() => matrixRTCSession.membershipStatus ?? Status.Unknown),
|
||||||
),
|
),
|
||||||
Status.Unknown,
|
matrixRTCSession.membershipStatus ?? Status.Unknown,
|
||||||
);
|
);
|
||||||
|
|
||||||
const membershipConnected$ = rtsSession$.pipe(
|
const membershipConnected$ = rtsSession$.pipe(
|
||||||
|
|||||||
Reference in New Issue
Block a user