12345678910111213141516171819202122232425262728 |
- package de.tudarmstadt.informatik.hostage.nio;
- import java.io.BufferedInputStream;
- import java.io.ByteArrayOutputStream;
- import java.io.IOException;
- import java.io.InputStream;
- import de.tudarmstadt.informatik.hostage.wrapper.Packet;
- public class Reader {
- BufferedInputStream in;
- String protocol;
- public Reader(InputStream in, String protocol) {
- this.in = new BufferedInputStream(in);
- this.protocol = protocol;
- }
- public Packet read() throws IOException {
- ByteArrayOutputStream payload = new ByteArrayOutputStream();
- while(in.available() > 0){
- payload.write(in.read());
- }
- return new Packet(payload.toByteArray(), protocol);
- }
- }
|