| 22 | type ModCustomizePubSessionOptionFn func(option *CustomizePubSessionOption) |
| 23 | |
| 24 | type CustomizePubSessionContext struct { |
| 25 | uniqueKey string |
| 26 | |
| 27 | streamName string |
| 28 | remuxer *remux.AvPacket2RtmpRemuxer |
| 29 | onRtmpMsg func(msg base.RtmpMsg) |
| 30 | option CustomizePubSessionOption |
| 31 | dumpFile *base.DumpFile |
| 32 | |
| 33 | disposeFlag nazaatomic.Bool |
| 34 | } |
| 35 | |
| 36 | func NewCustomizePubSessionContext(streamName string) *CustomizePubSessionContext { |
| 37 | s := &CustomizePubSessionContext{ |
nothing calls this directly
no outgoing calls
no test coverage detected