client: support reading with UDP-multicast

Author: aler9

README.md

@@ -16,7 +16,7 @@ Features:
 * Client
   * Query servers about available streams
   * Read
-    * Read streams from servers with UDP, TCP or TLS/RTSPS
+    * Read streams from servers with UDP, UDP-multicast, TCP or TLS/RTSPS
     * Switch protocol automatically (switch to TCP in case of server error or UDP timeout)
     * Read only selected tracks of a stream
     * Pause or seek without disconnecting from the server
@@ -31,7 +31,7 @@ Features:
   * Sessions and connections are independent
   * Read streams from clients with UDP, TCP or TLS/RTSPS
   * Write streams to clients with UDP, UDP-multicast, TCP or TLS/RTSPS
-  * Provide SSRC, RTP-Info automatically
+  * Provide SSRC, RTP-Info to clients automatically
   * Generate RTCP receiver reports automatically
 * Utilities
   * Encode and decode RTSP primitives, RTP/H264, RTP/AAC, SDP

client.go

@@ -35,6 +35,16 @@ func DialPublish(address string, tracks Tracks) (*ClientConn, error) {
 	return DefaultClient.DialPublish(address, tracks)
 }
 
+// ClientProtocol is a RTSP stream protocol used by the client.
+type ClientProtocol int
+
+// standard RTSP stream protocols.
+const (
+	ClientProtocolUDP ClientProtocol = iota
+	ClientProtocolMulticast
+	ClientProtocolTCP
+)
+
 // Client is a RTSP client.
 type Client struct {
 	//
@@ -64,10 +74,10 @@ type Client struct {
 	//
 	// reading / writing
 	//
-	// the stream protocol (UDP or TCP).
+	// the stream protocol (UDP, Multicast or TCP).
 	// If nil, it is chosen automatically (first UDP, then, if it fails, TCP).
 	// It defaults to nil.
-	StreamProtocol *base.StreamProtocol
+	Protocol *ClientProtocol
 	// If the client is reading with UDP, it must receive
 	// at least a packet within this timeout.
 	// It defaults to 3 seconds.

client_publish_test.go

@@ -162,12 +162,12 @@ func TestClientPublishSerial(t *testing.T) {
 			}()
 
 			c := &Client{
-				StreamProtocol: func() *base.StreamProtocol {
+				Protocol: func() *ClientProtocol {
 					if proto == "udp" {
-						v := base.StreamProtocolUDP
+						v := ClientProtocolUDP
 						return &v
 					}
-					v := base.StreamProtocolTCP
+					v := ClientProtocolTCP
 					return &v
 				}(),
 			}
@@ -304,12 +304,12 @@ func TestClientPublishParallel(t *testing.T) {
 			}()
 
 			c := &Client{
-				StreamProtocol: func() *base.StreamProtocol {
+				Protocol: func() *ClientProtocol {
 					if proto == "udp" {
-						v := base.StreamProtocolUDP
+						v := ClientProtocolUDP
 						return &v
 					}
-					v := base.StreamProtocolTCP
+					v := ClientProtocolTCP
 					return &v
 				}(),
 			}
@@ -462,12 +462,12 @@ func TestClientPublishPauseSerial(t *testing.T) {
 			}()
 
 			c := &Client{
-				StreamProtocol: func() *base.StreamProtocol {
+				Protocol: func() *ClientProtocol {
 					if proto == "udp" {
-						v := base.StreamProtocolUDP
+						v := ClientProtocolUDP
 						return &v
 					}
-					v := base.StreamProtocolTCP
+					v := ClientProtocolTCP
 					return &v
 				}(),
 			}
@@ -600,12 +600,12 @@ func TestClientPublishPauseParallel(t *testing.T) {
 			}()
 
 			c := &Client{
-				StreamProtocol: func() *base.StreamProtocol {
+				Protocol: func() *ClientProtocol {
 					if proto == "udp" {
-						v := base.StreamProtocolUDP
+						v := ClientProtocolUDP
 						return &v
 					}
-					v := base.StreamProtocolTCP
+					v := ClientProtocolTCP
 					return &v
 				}(),
 			}
@@ -883,8 +883,8 @@ func TestClientPublishRTCPReport(t *testing.T) {
 	}()
 
 	c := &Client{
-		StreamProtocol: func() *base.StreamProtocol {
-			v := base.StreamProtocolTCP
+		Protocol: func() *ClientProtocol {
+			v := ClientProtocolTCP
 			return &v
 		}(),
 		senderReportPeriod: 1 * time.Second,