From 38d65c4b7d7015a9f885318ede755bd6e6bcc185 Mon Sep 17 00:00:00 2001 From: 0xboobface <0xboobface@gmail.com> Date: Thu, 4 Apr 2019 19:11:03 +0200 Subject: [PATCH] Remove test class --- .../main/java/org/taktik/mpegts/Merger.java | 63 ------------------- 1 file changed, 63 deletions(-) delete mode 100644 common/src/main/java/org/taktik/mpegts/Merger.java diff --git a/common/src/main/java/org/taktik/mpegts/Merger.java b/common/src/main/java/org/taktik/mpegts/Merger.java deleted file mode 100644 index c3d9e65e..00000000 --- a/common/src/main/java/org/taktik/mpegts/Merger.java +++ /dev/null @@ -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(); - } - } - -}