| 220 | } |
| 221 | |
| 222 | func (packer *MessagePacker) writeOnStatusPlay(writer io.Writer, streamid int) error { |
| 223 | packer.b.ModWritePos(12) |
| 224 | |
| 225 | // 96 |
| 226 | _ = Amf0.WriteString(packer.b, "onStatus") |
| 227 | _ = Amf0.WriteNumber(packer.b, 0) |
| 228 | _ = Amf0.WriteNull(packer.b) |
| 229 | objs := []ObjectPair{ |
| 230 | {Key: "level", Value: "status"}, |
| 231 | {Key: "code", Value: "NetStream.Play.Start"}, |
| 232 | {Key: "description", Value: "Start live"}, |
| 233 | } |
| 234 | _ = Amf0.WriteObject(packer.b, objs) |
| 235 | |
| 236 | return packer.ChunkAndWrite(writer, csidOverStream, base.RtmpTypeIdCommandMessageAmf0, streamid) |
| 237 | } |
| 238 | |
| 239 | func (packer *MessagePacker) writeStreamIsRecorded(writer io.Writer, streamid uint32) error { |
| 240 | packer.b.ModWritePos(12) |