@@ -198,10 +198,11 @@ def __receive_worker(self):
198198 usage : Dict [str , Any ] = None
199199 usages : List [Any ] = None
200200 if 'sentence' in part .output :
201- if (self ._first_package_timestamp < 0 ):
202- self ._first_package_timestamp = time .time () * 1000
203- logger .debug ('first package delay {}' .format (
204- self .get_first_package_delay ()))
201+ if 'text' in part .output ['sentence' ] and part .output ['sentence' ]['text' ] != '' :
202+ if (self ._first_package_timestamp < 0 ):
203+ self ._first_package_timestamp = time .time () * 1000
204+ logger .debug ('first package delay {}' .format (
205+ self .get_first_package_delay ()))
205206 sentence = part .output ['sentence' ]
206207 if 'heartbeat' in sentence and sentence ['heartbeat' ] == True :
207208 logger .debug ('recv heartbeat' )
@@ -388,11 +389,12 @@ def call(self,
388389 for part in responses :
389390 if part .status_code == HTTPStatus .OK :
390391 if 'sentence' in part .output :
391- if (self ._first_package_timestamp < 0 ):
392- self ._first_package_timestamp = time .time () * 1000
393- logger .debug ('first package delay {}' .format (
394- self ._first_package_timestamp -
395- self ._start_stream_timestamp ))
392+ if 'text' in part .output ['sentence' ] and part .output ['sentence' ]['text' ] != '' :
393+ if (self ._first_package_timestamp < 0 ):
394+ self ._first_package_timestamp = time .time () * 1000
395+ logger .debug ('first package delay {}' .format (
396+ self ._first_package_timestamp -
397+ self ._start_stream_timestamp ))
396398 sentence = part .output ['sentence' ]
397399 logger .debug (
398400 'Recv Result [rid:{}]:{}, isEnd: {}' .format (
0 commit comments