mirror of
https://github.com/aler9/gortsplib
synced 2025-10-05 15:16:51 +08:00
add client close test
This commit is contained in:
@@ -246,6 +246,39 @@ func TestClientDescribeCharset(t *testing.T) {
|
|||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestClientClose(t *testing.T) {
|
||||||
|
u, err := base.ParseURL("rtsp://localhost:8554/teststream")
|
||||||
|
require.NoError(t, err)
|
||||||
|
|
||||||
|
c := Client{}
|
||||||
|
|
||||||
|
err = c.Start(u.Scheme, u.Host)
|
||||||
|
require.NoError(t, err)
|
||||||
|
|
||||||
|
c.Close()
|
||||||
|
|
||||||
|
_, err = c.Options(u)
|
||||||
|
require.EqualError(t, err, "terminated")
|
||||||
|
|
||||||
|
_, _, _, err = c.Describe(u)
|
||||||
|
require.EqualError(t, err, "terminated")
|
||||||
|
|
||||||
|
_, err = c.Announce(u, nil)
|
||||||
|
require.EqualError(t, err, "terminated")
|
||||||
|
|
||||||
|
_, err = c.Setup(true, nil, nil, 0, 0)
|
||||||
|
require.EqualError(t, err, "terminated")
|
||||||
|
|
||||||
|
_, err = c.Play(nil)
|
||||||
|
require.EqualError(t, err, "terminated")
|
||||||
|
|
||||||
|
_, err = c.Record()
|
||||||
|
require.EqualError(t, err, "terminated")
|
||||||
|
|
||||||
|
_, err = c.Pause()
|
||||||
|
require.EqualError(t, err, "terminated")
|
||||||
|
}
|
||||||
|
|
||||||
func TestClientCloseDuringRequest(t *testing.T) {
|
func TestClientCloseDuringRequest(t *testing.T) {
|
||||||
l, err := net.Listen("tcp", "localhost:8554")
|
l, err := net.Listen("tcp", "localhost:8554")
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
|
Reference in New Issue
Block a user