File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -47,7 +47,7 @@ fn link_import(
47
47
let import_tuple = tuple:: get_tuple ( definition) ?;
48
48
49
49
let import_type = import_tuple
50
- . get ( 0 )
50
+ . first ( )
51
51
. ok_or ( Error :: Atom ( "missing_import_type" ) ) ?;
52
52
let import_type =
53
53
Atom :: from_term ( * import_type) . map_err ( |_| Error :: Atom ( "import type must be an atom" ) ) ?;
@@ -126,7 +126,7 @@ fn link_imported_function(
126
126
let caller_token = set_caller ( caller) ;
127
127
128
128
let mut msg_env = OwnedEnv :: new ( ) ;
129
- msg_env. send_and_clear ( & pid. clone ( ) , |env| {
129
+ let result = msg_env. send_and_clear ( & pid. clone ( ) , |env| {
130
130
let mut callback_params: Vec < Term > = Vec :: with_capacity ( params. len ( ) ) ;
131
131
for value in params {
132
132
callback_params. push ( match value {
@@ -183,6 +183,8 @@ fn link_imported_function(
183
183
. encode ( env)
184
184
} ) ;
185
185
186
+ result. expect ( "expect no send error" ) ;
187
+
186
188
// Wait for the thread to start up - `receive_callback_result` is responsible for that.
187
189
let mut result = callback_token. token . return_values . lock ( ) . unwrap ( ) ;
188
190
while result. is_none ( ) {
You can’t perform that action at this time.
0 commit comments