Make stream.Write public

Author: tobbee

client_conn.go

@@ -39,7 +39,7 @@ func newClientConnWithSetup(c net.Conn, config *ConnConfig) (*ClientConn, error)
 	}
 	ctrlStream.handler.ChangeState(streamStateClientNotConnected)
 
-	conn.streamer.controlStreamWriter = ctrlStream.write
+	conn.streamer.controlStreamWriter = ctrlStream.Write
 
 	cc := &ClientConn{
 		conn: conn,

server_conn.go

@@ -37,7 +37,7 @@ func (sc *serverConn) Serve() error {
 	}
 	ctrlStream.handler.ChangeState(streamStateServerNotConnected)
 
-	sc.conn.streamer.controlStreamWriter = ctrlStream.write
+	sc.conn.streamer.controlStreamWriter = ctrlStream.Write
 
 	if sc.conn.handler != nil {
 		sc.conn.handler.OnServe(sc.conn)

stream.go

@@ -46,15 +46,15 @@ func newStream(streamID uint32, conn *Conn) *Stream {
 }
 
 func (s *Stream) WriteWinAckSize(chunkStreamID int, timestamp uint32, msg *message.WinAckSize) error {
-	return s.write(chunkStreamID, timestamp, msg)
+	return s.Write(chunkStreamID, timestamp, msg)
 }
 
 func (s *Stream) WriteSetPeerBandwidth(chunkStreamID int, timestamp uint32, msg *message.SetPeerBandwidth) error {
-	return s.write(chunkStreamID, timestamp, msg)
+	return s.Write(chunkStreamID, timestamp, msg)
 }
 
 func (s *Stream) WriteUserCtrl(chunkStreamID int, timestamp uint32, msg *message.UserCtrl) error {
-	return s.write(chunkStreamID, timestamp, msg)
+	return s.Write(chunkStreamID, timestamp, msg)
 }
 
 func (s *Stream) Connect(
@@ -249,7 +249,7 @@ func (s *Stream) writeCommandMessage(
 		return err
 	}
 
-	return s.write(chunkStreamID, timestamp, &message.CommandMessage{
+	return s.Write(chunkStreamID, timestamp, &message.CommandMessage{
 		CommandName:   commandName,
 		TransactionID: transactionID,
 		Encoding:      s.encTy,
@@ -269,14 +269,14 @@ func (s *Stream) WriteDataMessage(
 		return err
 	}
 
-	return s.write(chunkStreamID, timestamp, &message.DataMessage{
+	return s.Write(chunkStreamID, timestamp, &message.DataMessage{
 		Name:     name,
 		Encoding: message.EncodingTypeAMF0,
 		Body:     buf,
 	})
 }
 
-func (s *Stream) write(chunkStreamID int, timestamp uint32, msg message.Message) error {
+func (s *Stream) Write(chunkStreamID int, timestamp uint32, msg message.Message) error {
 	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second) // TODO: Fix 5s
 	defer cancel()