davebluke
/
ctbrec
forked from j62/ctbrec
1
0
Fork 0
Code Pull Requests Activity

Remove test class

This commit is contained in:
0xboobface 2019-04-04 19:11:03 +02:00
parent 73221ce881
commit 38d65c4b7d
1 changed files with 0 additions and 63 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

63
common/src/main/java/org/taktik/mpegts/Merger.java
View File

@ -1,63 +0,0 @@
package org.taktik.mpegts;
import static java.nio.file.StandardOpenOption.CREATE;
import static java.nio.file.StandardOpenOption.WRITE;
import java.io.File;
import java.io.IOException;
import java.nio.channels.FileChannel;
import java.util.Arrays;
import org.taktik.mpegts.sinks.ByteChannelSink;
import org.taktik.mpegts.sinks.MTSSink;
import org.taktik.mpegts.sources.MTSSource;
import org.taktik.mpegts.sources.MTSSources;
import org.taktik.mpegts.sources.MultiplexingMTSSource;
import org.taktik.mpegts.sources.MultiplexingMTSSource.MultiplexingMTSSourceBuilder;
public class Merger {
public static void main(String[] args) throws IOException {
File[] files = new File("/home/henni/devel/ctbrec/remux-ts-mp4/src/test/resources").listFiles((f) -> f.getName().startsWith("63"));
//File[] files = new File("/home/henni/devel/ctbrec/mpegts-streamer/src/test/resources/yesikasaenz/2018-09-04_23-30").listFiles((f) -> {
// return f.getName().startsWith("media") && f.getName().endsWith(".ts");
// });
Arrays.sort(files);
MultiplexingMTSSourceBuilder builder = MultiplexingMTSSource.builder()
.setFixContinuity(true);
for (File file : files) {
MTSSource source = MTSSources.from(file);
builder.addSource(source);
}
File out = new File("merged.ts");
FileChannel channel = null;
try {
channel = FileChannel.open(out.toPath(), CREATE, WRITE);
MTSSource mtsSource = builder.build();
MTSSink sink = ByteChannelSink.builder().setByteChannel(channel).build();
// build streamer
Streamer streamer = Streamer.builder()
.setSource(mtsSource)
.setSink(sink)
.build();
// Start streaming
streamer.stream();
// synchronized (streamer) {
// System.out.println("Waiting for streamer to finish");
// streamer.wait();
// System.out.println("Streamer finished");
// }
} catch(Exception e) {
e.printStackTrace();
} finally {
channel.close();
}
}
}