import net.pterodactylus.sonitus.data.AbstractFilter;
import net.pterodactylus.sonitus.data.Controller;
+import net.pterodactylus.sonitus.data.DataPacket;
+import net.pterodactylus.sonitus.data.Filter;
import net.pterodactylus.sonitus.data.Metadata;
import net.pterodactylus.sonitus.io.InputStreamDrainer;
import com.google.common.io.Closeables;
/**
- * {@link net.pterodactylus.sonitus.data.Sink} implementation that delivers all
- * incoming data to an Icecast2 server.
+ * {@link Filter} implementation that delivers all incoming data to an Icecast2
+ * server.
*
* @author <a href="mailto:bombe@pterodactylus.net">David ‘Bombe’ Roden</a>
*/
/**
* Creates a new Icecast2 sink.
*
- * @param eventBus
- * The event bus
* @param server
* The hostname of the server
* @param port
}
@Override
- public void process(byte[] buffer) throws IOException {
- socketOutputStream.write(buffer);
+ public void process(DataPacket dataPacket) throws IOException {
+ socketOutputStream.write(dataPacket.buffer());
socketOutputStream.flush();
}