// Create a cancellable context in case you want to stop reading packets/data any time you want ctx, cancel := context.WithCancel(context.Background()) // Handle SIGTERM signal ch := make(chan os.Signal, 1) signal.Notify(ch, syscall.SIGTERM) go func() { <-ch cancel() }() // Open your file or initialize any kind of io.Reader // Buffering using bufio.Reader is recommended for performance f, _ := os.Open("/path/to/file.ts") defer f.Close() // Create the demuxer dmx := astits.NewDemuxer(ctx, f) for { // Get the next data d, _ := dmx.NextData() // Data is a PMT data if d.PMT != nil { // Loop through elementary streams for _, es := range d.PMT.ElementaryStreams { fmt.Printf("Stream detected: %d\n", es.ElementaryPID) } return } }

// Create a cancellable context in case you want to stop writing packets/data any time you want ctx, cancel := context.WithCancel(context.Background()) // Handle SIGTERM signal ch := make(chan os.Signal, 1) signal.Notify(ch, syscall.SIGTERM) go func() { <-ch cancel() }() // Create your file or initialize any kind of io.Writer // Buffering using bufio.Writer is recommended for performance f, _ := os.Create("/path/to/file.ts") defer f.Close() // Create the muxer mx := astits.NewMuxer(ctx, f) // Add an elementary stream mx.AddElementaryStream(astits.PMTElementaryStream{ ElementaryPID: 1, StreamType: astits.StreamTypeMetadata, }) // Write tables // Using that function is not mandatory, WriteData will retransmit tables from time to time  mx.WriteTables() // Write data mx.WriteData(&astits.MuxerData{ PES: &astits.PESData{ Data: []byte("test"), }, PID: 1, })

// This is your custom packets parser p := func(ps []*astits.Packet) (ds []*astits.Data, skip bool, err error) { // This is your logic skip = true return } // Now you can create a demuxer with the proper options dmx := NewDemuxer(ctx, f, DemuxerOptPacketSize(192), DemuxerOptPacketsParser(p))