@@ -142,9 +142,7 @@ impl MobileConvexClient {
142142 args : HashMap < String , String > ,
143143 ) -> Result < String , ClientError > {
144144 let mut client = self . connected_client ( ) . await ?;
145- debug ! ( "got the client" ) ;
146145 let result = client. query ( name. as_str ( ) , parse_json_args ( args) ) . await ?;
147- debug ! ( "got the result" ) ;
148146 handle_direct_function_result ( result)
149147 }
150148
@@ -171,7 +169,7 @@ impl MobileConvexClient {
171169 subscriber : Arc < dyn QuerySubscriber > ,
172170 ) -> anyhow:: Result < Arc < SubscriptionHandle > > {
173171 let mut client = self . connected_client ( ) . await ?;
174- debug ! ( "New subscription" ) ;
172+ debug ! ( "New subscription to {}" , name ) ;
175173 let mut subscription = client
176174 . subscribe ( name. as_str ( ) , parse_json_args ( args) )
177175 . await ?;
@@ -185,7 +183,6 @@ impl MobileConvexClient {
185183 let new_val = new_val. expect( "Client dropped prematurely" ) ;
186184 match new_val {
187185 FunctionResult :: Value ( value) => {
188- debug!( "Updating with {value:?}" ) ;
189186 subscriber. on_update( serde_json:: to_string(
190187 & serde_json:: Value :: from( value)
191188 ) . unwrap( ) )
@@ -217,6 +214,7 @@ impl MobileConvexClient {
217214 name : String ,
218215 args : HashMap < String , String > ,
219216 ) -> Result < String , ClientError > {
217+ debug ! ( "Running mutation: {}" , name) ;
220218 let result = self . internal_mutation ( name, args) . await ?;
221219
222220 handle_direct_function_result ( result)
@@ -244,7 +242,6 @@ impl MobileConvexClient {
244242 ) -> Result < String , ClientError > {
245243 debug ! ( "Running action: {}" , name) ;
246244 let result = self . internal_action ( name, args) . await ?;
247- debug ! ( "Got action result: {:?}" , result) ;
248245 handle_direct_function_result ( result)
249246 }
250247
@@ -254,7 +251,6 @@ impl MobileConvexClient {
254251 args : HashMap < String , String > ,
255252 ) -> anyhow:: Result < FunctionResult > {
256253 let mut client = self . connected_client ( ) . await ?;
257- debug ! ( "Running action: {}" , name) ;
258254 self . rt
259255 . spawn ( async move { client. action ( & name, parse_json_args ( args) ) . await } )
260256 . await ?
0 commit comments