new Thread(connection, threadName).start();
currentSource = filter;
}
+ metadataUpdated(currentMetadata);
}
@Override
public DataPacket get(int bufferSize) throws IOException {
+ if (filterConnections.get(lastFilter).ioException().isPresent()) {
+ throw filterConnections.get(lastFilter).ioException().get();
+ }
return lastFilter.get(bufferSize);
}