mirror
/
av
mirror of https://bitbucket.org/ausocean/av.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Removed references to obsolete Session.

This commit is contained in:
scruzin 2019-04-10 16:32:07 +09:30
parent d4c6a8f2a3
commit 863db58a84
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
protocol/rtmp/packet.go
View File

@ -259,7 +259,7 @@ func (pkt *packet) resize(size uint32, ht uint8) {
} }
// writeTo writes a packet to the RTMP connection. // writeTo writes a packet to the RTMP connection.
// Packets are written in chunks which are Session.chunkSize in length (128 bytes in length). // Packets are written in chunks which are c.chunkSize in length (128 bytes by default).
// We defer sending small audio packets and combine consecutive small audio packets where possible to reduce I/O. // We defer sending small audio packets and combine consecutive small audio packets where possible to reduce I/O.
// When queue is true, we expect a response to this request and cache the method on c.methodCalls. // When queue is true, we expect a response to this request and cache the method on c.methodCalls.
func (pkt *packet) writeTo(c *Conn, queue bool) error { func (pkt *packet) writeTo(c *Conn, queue bool) error {

4
protocol/rtmp/rtmp_test.go
View File

@ -206,7 +206,7 @@ func TestFromFrame(t *testing.T) {
err = c.Close() err = c.Close()
if err != nil { if err != nil {
t.Errorf("Session.Close failed with error: %v", err) t.Errorf("Conn.Close failed with error: %v", err)
} }
} }
@ -256,6 +256,6 @@ func TestFromFile(t *testing.T) {
err = c.Close() err = c.Close()
if err != nil { if err != nil {
t.Errorf("Session.Close failed with error: %v", err) t.Errorf("Conn.Close failed with error: %v", err)
} }
} }