| 150 | } |
| 151 | |
| 152 | func (packer *MessagePacker) writeCreateStream(writer io.Writer) error { |
| 153 | packer.b.ModWritePos(12) |
| 154 | |
| 155 | // 25 = 15 + 9 + 1 |
| 156 | _ = Amf0.WriteString(packer.b, "createStream") |
| 157 | _ = Amf0.WriteNumber(packer.b, float64(tidClientCreateStream)) |
| 158 | _ = Amf0.WriteNull(packer.b) |
| 159 | |
| 160 | return packer.ChunkAndWrite(writer, csidOverConnection, base.RtmpTypeIdCommandMessageAmf0, 0) |
| 161 | } |
| 162 | |
| 163 | func (packer *MessagePacker) writeCreateStreamResult(writer io.Writer, tid int) error { |
| 164 | packer.b.ModWritePos(12) |