|
@@ -10,17 +10,25 @@ impl crate::Liveview {
|
|
pub async fn upgrade(&self, ws: warp::ws::WebSocket, app: fn(Scope) -> Element) {
|
|
pub async fn upgrade(&self, ws: warp::ws::WebSocket, app: fn(Scope) -> Element) {
|
|
connect(ws, self.pool.clone(), app, ()).await;
|
|
connect(ws, self.pool.clone(), app, ()).await;
|
|
}
|
|
}
|
|
- pub async fn upgrade_with_props<T>(&self, ws: warp::ws::WebSocket, app: fn(Scope<T>) -> Element, props: T)
|
|
|
|
- where
|
|
|
|
- T: Send + Sync + 'static
|
|
|
|
|
|
+ pub async fn upgrade_with_props<T>(
|
|
|
|
+ &self,
|
|
|
|
+ ws: warp::ws::WebSocket,
|
|
|
|
+ app: fn(Scope<T>) -> Element,
|
|
|
|
+ props: T,
|
|
|
|
+ ) where
|
|
|
|
+ T: Send + Sync + 'static,
|
|
{
|
|
{
|
|
connect(ws, self.pool.clone(), app, props).await;
|
|
connect(ws, self.pool.clone(), app, props).await;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
-pub async fn connect<T>(ws: WebSocket, pool: LocalPoolHandle, app: fn(Scope<T>) -> Element, props: T)
|
|
|
|
-where
|
|
|
|
- T: Send + Sync+ 'static
|
|
|
|
|
|
+pub async fn connect<T>(
|
|
|
|
+ ws: WebSocket,
|
|
|
|
+ pool: LocalPoolHandle,
|
|
|
|
+ app: fn(Scope<T>) -> Element,
|
|
|
|
+ props: T,
|
|
|
|
+) where
|
|
|
|
+ T: Send + Sync + 'static,
|
|
{
|
|
{
|
|
// Use a counter to assign a new unique ID for this user.
|
|
// Use a counter to assign a new unique ID for this user.
|
|
|
|
|