Merge pull request yutopp#35 from octu0/playback-support

[proposal] add playback support

Author: yutopp

conn.go

@@ -9,6 +9,7 @@ package rtmp
 
 import (
 	"bufio"
+	"context"
 	"github.com/hashicorp/go-multierror"
 	"github.com/pkg/errors"
 	"github.com/sirupsen/logrus"
@@ -131,6 +132,10 @@ func (c *Conn) Close() error {
 	return result
 }
 
+func (c *Conn) Write(ctx context.Context, chunkStreamID int, timestamp uint32, cmsg *ChunkMessage) error {
+	return c.streamer.Write(ctx, chunkStreamID, timestamp, cmsg)
+}
+
 func (c *Conn) handleMessageLoop() (err error) {
 	defer func() {
 		if r := recover(); r != nil {

message/body_decoder.go

@@ -222,7 +222,15 @@ func DecodeBodyPlay(_ io.Reader, d AMFDecoder, v *AMFConvertible) error {
 	}
 	var start int64
 	if err := d.Decode(&start); err != nil {
-		return errors.Wrap(err, "Failed to decode 'play' args[2]")
+		//
+		// io.EOF occurs when the start position is not specified.
+		//  'NetStream.play(streamName,null)'
+		// set start to 0 to avoid it.
+		//
+		if err != io.EOF {
+			return errors.Wrap(err, "Failed to decode 'play' args[2]")
+		}
+		start = 0
 	}
 
 	var cmd NetStreamPlay