X-Git-Url: https://git.pterodactylus.net/?p=sonitus.git;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsonitus%2Fdata%2Fsource%2FFileSource.java;h=01216cd0c910d12416679451e362786903f2d7a9;hp=7251f654d107ac7f10678990ffe6631e49c622e2;hb=3a12209e82233cd79677a0d847321f41b41aa9a5;hpb=58ada95cc9cda6e07371c5c560736bbb4eeba9da diff --git a/src/main/java/net/pterodactylus/sonitus/data/source/FileSource.java b/src/main/java/net/pterodactylus/sonitus/data/source/FileSource.java index 7251f65..01216cd 100644 --- a/src/main/java/net/pterodactylus/sonitus/data/source/FileSource.java +++ b/src/main/java/net/pterodactylus/sonitus/data/source/FileSource.java @@ -29,6 +29,7 @@ import java.util.List; 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.IdentifyingInputStream; @@ -82,13 +83,13 @@ public class FileSource extends AbstractFilter { } @Override - public byte[] get(int bufferSize) throws IOException { + public DataPacket get(int bufferSize) throws IOException { byte[] buffer = new byte[bufferSize]; int read = fileInputStream.read(buffer); if (read == -1) { throw new EOFException(); } - return Arrays.copyOf(buffer, read); + return new DataPacket(metadata(), Arrays.copyOf(buffer, read)); } //