@@ -162,16 +162,16 @@ export default class RTSPClient extends EventEmitter {
162162 //
163163 // Handles receiving data & closing port, called during
164164 // #connect.
165- _netConnect ( hostname : string , port : number , secure : boolean = false ) : Promise < this> {
165+ _netConnect ( hostname : string , port : number , secure = false ) : Promise < this> {
166166 return new Promise ( ( resolve , reject ) => {
167167 // Set after listeners defined.
168168
169- const errorListener = ( err : any ) => {
169+ const errorListener = ( err : Error ) => {
170170 client . removeListener ( "error" , errorListener ) ;
171171 reject ( err ) ;
172172 } ;
173173
174- const postConnectErrorListener = ( err : any ) => {
174+ const postConnectErrorListener = ( err : Error ) => {
175175 client . removeListener ( "error" , postConnectErrorListener ) ;
176176 this . emit ( "error" , err ) ;
177177 reject ( err ) ;
@@ -400,8 +400,8 @@ export default class RTSPClient extends EventEmitter {
400400 const rtpPort = rtpChannel ;
401401 rtpReceiver = dgram . createSocket ( "udp4" ) ;
402402
403- rtpReceiver . on ( "message" , ( buf , remote ) => {
404- let packet = parseRTPPacket ( buf ) ;
403+ rtpReceiver . on ( "message" , ( buf ) => {
404+ const packet = parseRTPPacket ( buf ) ;
405405
406406 // Add wall clock time
407407 const detail = this . setupResult . find ( item => item . rtpChannel == rtpChannel ) ;
@@ -418,7 +418,7 @@ export default class RTSPClient extends EventEmitter {
418418
419419 // If this is a Sender Report, cache the NTP Wall Clock data
420420 if ( packet . packetType == 200 && packet . senderReport != undefined ) {
421- let detail = this . setupResult . find ( item => item . rtcpChannel == rtcpChannel ) ;
421+ const detail = this . setupResult . find ( item => item . rtcpChannel == rtcpChannel ) ;
422422 if ( detail != undefined ) {
423423 detail . sr_ntpMSW = packet . senderReport . ntpTimestampMSW ;
424424 detail . sr_ntpLSW = packet . senderReport . ntpTimestampLSW ;
@@ -820,7 +820,7 @@ export default class RTSPClient extends EventEmitter {
820820 const packetChannel = this . messageBytes [ 1 ] ;
821821 if ( ( packetChannel & 0x01 ) === 0 ) {
822822 // even number
823- let packet = parseRTPPacket ( this . rtspPacket ) ;
823+ const packet = parseRTPPacket ( this . rtspPacket ) ;
824824
825825 // Get the Session Detail
826826 const detail = this . setupResult . find ( item => item . rtpChannel == packetChannel ) ;
@@ -834,7 +834,7 @@ export default class RTSPClient extends EventEmitter {
834834
835835 // If this is a Sender Report, cache the NTP Wall Clock data
836836 if ( packet . packetType == 200 && packet . senderReport != undefined ) {
837- let detail = this . setupResult . find ( item => item . rtcpChannel == packetChannel ) ;
837+ const detail = this . setupResult . find ( item => item . rtcpChannel == packetChannel ) ;
838838 if ( detail != undefined ) {
839839 detail . sr_ntpMSW = packet . senderReport . ntpTimestampMSW ;
840840 detail . sr_ntpLSW = packet . senderReport . ntpTimestampLSW ;
@@ -972,7 +972,7 @@ export default class RTSPClient extends EventEmitter {
972972
973973 _sendUDPData ( host : string , port : number , buffer : Buffer ) : void {
974974 const udp = dgram . createSocket ( "udp4" ) ;
975- udp . send ( buffer , 0 , buffer . length , port , host , ( err , bytes ) => {
975+ udp . send ( buffer , 0 , buffer . length , port , host , ( _err , _bytes ) => {
976976 // TODO: Don't ignore errors.
977977 udp . close ( ) ;
978978 } ) ;
@@ -997,10 +997,10 @@ export default class RTSPClient extends EventEmitter {
997997 return report ;
998998 }
999999
1000- async _socketWrite ( socket : SocketUnion , data : Buffer ) : Promise < any > {
1000+ async _socketWrite ( socket : SocketUnion , data : Buffer ) : Promise < void > {
10011001 return new Promise ( ( resolve , reject ) => {
10021002 setTimeout ( ( ) => {
1003- socket . write ( data , ( error : any ) => {
1003+ socket . write ( data , ( error : Error | null ) => {
10041004 if ( error ) {
10051005 reject ( error ) ;
10061006 } else {
@@ -1018,11 +1018,11 @@ export default class RTSPClient extends EventEmitter {
10181018
10191019 // Add Wall Clock Time
10201020 if ( detail . sr_ntpMSW != undefined && detail . sr_ntpLSW != undefined && detail . sr_rtptimestamp != undefined && detail . mediaSource . rtp [ 0 ] . rate != undefined ) {
1021- let refTimestampSecs = detail . sr_rtptimestamp / detail . mediaSource . rtp [ 0 ] . rate ; // H264 is 90 kHz clock rate
1022- let packetTimestampSecs = packet . timestamp / detail . mediaSource . rtp [ 0 ] . rate ; // eg 90kHz
1023- let packetTimestampDeltaSecs = packetTimestampSecs - refTimestampSecs ;
1024- let refTimestamp = new Date ( this . ntpBaseDate_ms + ( detail . sr_ntpMSW * 1000 ) + ( ( detail . sr_ntpLSW / Math . pow ( 2 , 32 ) ) * 1000 ) ) ;
1025- let wallclockTime = new Date ( refTimestamp . getTime ( ) + ( packetTimestampDeltaSecs * 1000 ) ) ;
1021+ const refTimestampSecs = detail . sr_rtptimestamp / detail . mediaSource . rtp [ 0 ] . rate ; // H264 is 90 kHz clock rate
1022+ const packetTimestampSecs = packet . timestamp / detail . mediaSource . rtp [ 0 ] . rate ; // eg 90kHz
1023+ const packetTimestampDeltaSecs = packetTimestampSecs - refTimestampSecs ;
1024+ const refTimestamp = new Date ( this . ntpBaseDate_ms + ( detail . sr_ntpMSW * 1000 ) + ( ( detail . sr_ntpLSW / Math . pow ( 2 , 32 ) ) * 1000 ) ) ;
1025+ const wallclockTime = new Date ( refTimestamp . getTime ( ) + ( packetTimestampDeltaSecs * 1000 ) ) ;
10261026 return wallclockTime ;
10271027 }
10281028
0 commit comments