File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
poem/subscription-redis/src Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -19,7 +19,7 @@ struct MutationRoot;
19
19
impl MutationRoot {
20
20
async fn publish ( & self , ctx : & Context < ' _ > , value : String ) -> Result < bool > {
21
21
let client = ctx. data_unchecked :: < Client > ( ) ;
22
- let mut conn = client. get_async_connection ( ) . await ?;
22
+ let mut conn = client. get_multiplexed_async_connection ( ) . await ?;
23
23
conn. publish ( "values" , value) . await ?;
24
24
Ok ( true )
25
25
}
@@ -31,7 +31,7 @@ struct SubscriptionRoot;
31
31
impl SubscriptionRoot {
32
32
async fn values ( & self , ctx : & Context < ' _ > ) -> Result < impl Stream < Item = String > > {
33
33
let client = ctx. data_unchecked :: < Client > ( ) ;
34
- let mut conn = client. get_async_connection ( ) . await ?. into_pubsub ( ) ;
34
+ let mut conn = client. get_async_pubsub ( ) . await ?;
35
35
conn. subscribe ( "values" ) . await ?;
36
36
Ok ( conn
37
37
. into_on_message ( )
You can’t perform that action at this time.
0 commit comments