11
11
from ._initialization_params import init_params_dict , init_key_aliases
12
12
from ._method_types import deferred_methods
13
13
from .integrations import _detect_render_type , _get_viewer_image , _get_viewer_point_sets
14
- from .integrations .environment import IN_JUPYTERLITE
14
+ from .integrations .environment import ENVIRONMENT , Env
15
15
from .render_types import RenderType
16
16
from .viewer_config import ITK_VIEWER_SRC , PYDATA_SPHINX_HREF , MUI_HREF
17
17
@@ -36,7 +36,7 @@ def __init__(
36
36
self .init_data = {}
37
37
self .img = display (HTML (f'<div />' ), display_id = str (uuid .uuid4 ()))
38
38
self .wid = None
39
- if not IN_JUPYTERLITE :
39
+ if ENVIRONMENT is not Env . JUPYTERLITE :
40
40
self .viewer_event = threading .Event ()
41
41
self .data_event = threading .Event ()
42
42
@@ -100,11 +100,10 @@ async def run(self, ctx):
100
100
config = config ,
101
101
)
102
102
_viewer_count += 1
103
- if not IN_JUPYTERLITE :
103
+ if ENVIRONMENT is not Env . JUPYTERLITE :
104
104
itk_viewer .registerEventListener (
105
105
'renderedImageAssigned' , self .set_event
106
106
)
107
- if not IN_JUPYTERLITE :
108
107
# Once the viewer has been created any queued requests can be run
109
108
asyncio .get_running_loop ().call_soon_threadsafe (self .viewer_event .set )
110
109
@@ -162,7 +161,7 @@ def __init__(
162
161
self .viewer_rpc = ViewerRPC (
163
162
ui_collapsed = ui_collapsed , rotate = rotate , ui = ui , ** add_data_kwargs
164
163
)
165
- if not IN_JUPYTERLITE :
164
+ if ENVIRONMENT is not Env . JUPYTERLITE :
166
165
self .bg_jobs = bg .BackgroundJobManager ()
167
166
self .queue = queue .Queue ()
168
167
self .deferred_queue = queue .Queue ()
@@ -173,6 +172,10 @@ def __init__(
173
172
def loop (self ):
174
173
return asyncio .get_running_loop ()
175
174
175
+ @property
176
+ def has_viewer (self ):
177
+ return hasattr (self .viewer_rpc , 'itk_viewer' )
178
+
176
179
async def run_queued_requests (self ):
177
180
def _run_queued_requests (queue ):
178
181
method_name , args , kwargs = queue .get ()
@@ -195,7 +198,7 @@ def queue_worker(self):
195
198
loop .run_until_complete (task )
196
199
197
200
def queue_request (self , method , * args , ** kwargs ):
198
- if IN_JUPYTERLITE or hasattr ( self .viewer_rpc , 'itk_viewer' ) :
201
+ if ENVIRONMENT is Env . JUPYTERLITE or self .has_viewer :
199
202
fn = getattr (self .viewer_rpc .itk_viewer , method )
200
203
fn (* args , ** kwargs )
201
204
elif method in deferred_methods ():
0 commit comments