|
|
@ -425,12 +425,6 @@ func TestClientInvalidSequenceID(t *testing.T) { |
|
|
|
require.NoError(t, err) |
|
|
|
require.NoError(t, err) |
|
|
|
defer s.close() |
|
|
|
defer s.close() |
|
|
|
|
|
|
|
|
|
|
|
packetRecv := make(chan struct{}) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
onH264 := func(pts time.Duration, dat interface{}) { |
|
|
|
|
|
|
|
close(packetRecv) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
c, err := NewClient( |
|
|
|
c, err := NewClient( |
|
|
|
"http://localhost:5780/stream.m3u8", |
|
|
|
"http://localhost:5780/stream.m3u8", |
|
|
|
"", |
|
|
|
"", |
|
|
@ -439,14 +433,11 @@ func TestClientInvalidSequenceID(t *testing.T) { |
|
|
|
require.NoError(t, err) |
|
|
|
require.NoError(t, err) |
|
|
|
|
|
|
|
|
|
|
|
c.OnTracks(func(tracks []format.Format) error { |
|
|
|
c.OnTracks(func(tracks []format.Format) error { |
|
|
|
c.OnData(tracks[0], onH264) |
|
|
|
|
|
|
|
return nil |
|
|
|
return nil |
|
|
|
}) |
|
|
|
}) |
|
|
|
|
|
|
|
|
|
|
|
c.Start() |
|
|
|
c.Start() |
|
|
|
|
|
|
|
|
|
|
|
<-packetRecv |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
err = <-c.Wait() |
|
|
|
err = <-c.Wait() |
|
|
|
require.EqualError(t, err, "following segment not found or not ready yet") |
|
|
|
require.EqualError(t, err, "following segment not found or not ready yet") |
|
|
|
|
|
|
|
|
|
|
|