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- 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 ( ( ) )
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+ }
183183 } ) ?)
184184 }
185185
You can’t perform that action at this time.
0 commit comments