diff --git a/rtmp/rtmp.go b/rtmp/rtmp.go index c706ef5c..366008f8 100644 --- a/rtmp/rtmp.go +++ b/rtmp/rtmp.go @@ -361,7 +361,7 @@ func (s *session) Write(data []byte) (int, error) { func startSession(rtmp *C.RTMP, u string, timeout uint32) (*C.RTMP, error) { connect_timeout := C.int(timeout) rtmp = rtmpAlloc() - C.RTMP_Init(rtmp) + rtmpInit(rtmp) rtmp.Link.timeout = connect_timeout if C.RTMP_SetupURL(rtmp, (*C.char)(unsafe.Pointer(goStrToCStr(u)))) == 0 { C.RTMP_Close(rtmp)