kozabrada123/chorus
kozabrada123
/
chorus
mirror of https://github.com/polyphony-chat/chorus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Replace Arc, Rwlock with Shared

This commit is contained in:
bitfl0wer 2024-01-21 20:24:17 +01:00
parent a571a9e137
commit 6637f14b18
No known key found for this signature in database
GPG Key ID: 0ACD574FCF5226CF
1 changed files with 3 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
tests/gateway.rs
View File

@ -1,10 +1,8 @@
mod common;
use std::sync::{Arc, RwLock};
use chorus::errors::GatewayError;
use chorus::gateway::*;
use chorus::types::{self, ChannelModifySchema, RoleCreateModifySchema, RoleObject};
use chorus::types::{self, ChannelModifySchema, Composite, RoleCreateModifySchema, RoleObject};
#[cfg(target_arch = "wasm32")]
use wasm_bindgen_test::*;
#[cfg(target_arch = "wasm32")]
@ -97,11 +95,7 @@ async fn test_recursive_self_updating_structs() {
.await
.unwrap();
// Watch role;
bundle
.user
.gateway
.observe(Arc::new(RwLock::new(role.clone())))
.await;
bundle.user.gateway.observe(role.into_shared()).await;
// Update Guild and check for Guild
let inner_guild = guild.read().unwrap().clone();
assert!(inner_guild.roles.is_some());
@ -113,7 +107,7 @@ async fn test_recursive_self_updating_structs() {
let role_inner = bundle
.user
.gateway
.observe_and_into_inner(Arc::new(RwLock::new(role.clone())))
.observe_and_into_inner(role.into_shared())
.await;
assert_eq!(role_inner.name, "yippieee");
// Check if the change propagated