@@ -173,9 +173,9 @@ def loop(self):
173
173
174
174
async def run_queued_requests (self ):
175
175
def _run_queued_requests (queue ):
176
- method_name , args = queue .get (). values ()
176
+ method_name , args , kwargs = queue .get ()
177
177
fn = getattr (self .viewer_rpc .itk_viewer , method_name )
178
- self .loop .call_soon_threadsafe (asyncio .ensure_future , fn (* args ))
178
+ self .loop .call_soon_threadsafe (asyncio .ensure_future , fn (* args , ** kwargs ))
179
179
180
180
# Wait for the viewer to be created
181
181
self .viewer_rpc .viewer_event .wait ()
@@ -192,14 +192,14 @@ def queue_worker(self):
192
192
task = loop .create_task (self .run_queued_requests ())
193
193
loop .run_until_complete (task )
194
194
195
- def queue_request (self , method , * args ):
195
+ def queue_request (self , method , * args , ** kwargs ):
196
196
if hasattr (self .viewer_rpc , 'itk_viewer' ):
197
197
fn = getattr (self .viewer_rpc .itk_viewer , method )
198
- fn (* args )
198
+ fn (* args , ** kwargs )
199
199
elif method in deferred_methods ():
200
- self .deferred_queue .put ({ ' method' : method , 'arg' : args } )
200
+ self .deferred_queue .put (( method , args , kwargs ) )
201
201
else :
202
- self .queue .put ({ ' method' : method , 'arg' : args } )
202
+ self .queue .put (( method , args , kwargs ) )
203
203
204
204
def set_annotations_enabled (self , enabled : bool ):
205
205
self .queue_request ('setAnnotationsEnabled' , enabled )
0 commit comments