@@ -483,15 +483,15 @@ impl Dispatcher {
483
483
if let Some ( http_stream) = self . http_streams . borrow_mut ( ) . get_mut ( & context_id) {
484
484
self . active_id . set ( context_id) ;
485
485
hostcalls:: set_effective_context ( context_id) . unwrap ( ) ;
486
- http_stream. on_grpc_stream_initial_metadata ( token_id, trailers) ;
486
+ http_stream. on_grpc_stream_trailing_metadata ( token_id, trailers) ;
487
487
} else if let Some ( stream) = self . streams . borrow_mut ( ) . get_mut ( & context_id) {
488
488
self . active_id . set ( context_id) ;
489
489
hostcalls:: set_effective_context ( context_id) . unwrap ( ) ;
490
- stream. on_grpc_stream_initial_metadata ( token_id, trailers) ;
490
+ stream. on_grpc_stream_trailing_metadata ( token_id, trailers) ;
491
491
} else if let Some ( root) = self . roots . borrow_mut ( ) . get_mut ( & context_id) {
492
492
self . active_id . set ( context_id) ;
493
493
hostcalls:: set_effective_context ( context_id) . unwrap ( ) ;
494
- root. on_grpc_stream_initial_metadata ( token_id, trailers) ;
494
+ root. on_grpc_stream_trailing_metadata ( token_id, trailers) ;
495
495
}
496
496
}
497
497
@@ -672,7 +672,7 @@ pub extern "C" fn proxy_on_grpc_receive(_context_id: u32, token_id: u32, respons
672
672
}
673
673
674
674
#[ no_mangle]
675
- pub extern "C" fn proxy_on_grpc_trailing_metadata ( _context_id : u32 , token_id : u32 , trailers : u32 ) {
675
+ pub extern "C" fn proxy_receive_on_grpc_trailing_metadata ( _context_id : u32 , token_id : u32 , trailers : u32 ) {
676
676
DISPATCHER . with ( |dispatcher| dispatcher. on_grpc_receive_trailing_metadata ( token_id, trailers) )
677
677
}
678
678
0 commit comments