File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -168,18 +168,18 @@ impl NatsCls {
168168 . map ( async_nats:: HeaderMap :: from_pydict)
169169 . transpose ( ) ?;
170170 Ok ( natsrpy_future ( py, async move {
171- if let Some ( session) = session. read ( ) . await . as_ref ( ) {
172- let request = async_nats :: Request {
173- payload : data ,
174- headers : headermap ,
175- inbox ,
176- timeout : timeout . map ( |t| Some ( std :: time :: Duration :: from_secs_f32 ( t ) ) ) ,
177- } ;
178- session . send_request ( subject , request ) . await ? ;
179- Ok ( ( ) )
180- } else {
181- Err ( NatsrpyError :: NotInitialized )
182- }
171+ let session = session. read ( ) . await ;
172+ let Some ( session ) = session . as_ref ( ) else {
173+ return Err ( NatsrpyError :: NotInitialized ) ;
174+ } ;
175+ let request = async_nats :: Request {
176+ payload : data ,
177+ headers : headermap ,
178+ inbox ,
179+ timeout : timeout . map ( |t| Some ( std :: time :: Duration :: from_secs_f32 ( t ) ) ) ,
180+ } ;
181+ session . send_request ( subject , request ) . await ? ;
182+ Ok ( ( ) )
183183 } ) ?)
184184 }
185185
You can’t perform that action at this time.
0 commit comments