projects
/
sonitus.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Expose metadata from every controlled component.
[sonitus.git]
/
src
/
main
/
java
/
net
/
pterodactylus
/
sonitus
/
data
/
sink
/
FileSink.java
diff --git
a/src/main/java/net/pterodactylus/sonitus/data/sink/FileSink.java
b/src/main/java/net/pterodactylus/sonitus/data/sink/FileSink.java
index
9bebc6b
..
92dd59a
100644
(file)
--- a/
src/main/java/net/pterodactylus/sonitus/data/sink/FileSink.java
+++ b/
src/main/java/net/pterodactylus/sonitus/data/sink/FileSink.java
@@
-43,6
+43,9
@@
public class FileSink implements Sink {
private FileOutputStream fileOutputStream;
private FileOutputStream fileOutputStream;
+ /** The current metadata. */
+ private Metadata metadata;
+
/**
* Creates a new file sink that will write to the given path.
*
/**
* Creates a new file sink that will write to the given path.
*
@@
-63,6
+66,11
@@
public class FileSink implements Sink {
}
@Override
}
@Override
+ public Metadata metadata() {
+ return metadata;
+ }
+
+ @Override
public List<Controller<?>> controllers() {
return Collections.emptyList();
}
public List<Controller<?>> controllers() {
return Collections.emptyList();
}
@@
-74,6
+82,7
@@
public class FileSink implements Sink {
@Override
public void open(Metadata metadata) throws IOException {
fileOutputStream = new FileOutputStream(path);
@Override
public void open(Metadata metadata) throws IOException {
fileOutputStream = new FileOutputStream(path);
+ metadataUpdated(metadata);
}
@Override
}
@Override
@@
-87,7
+96,7
@@
public class FileSink implements Sink {
@Override
public void metadataUpdated(Metadata metadata) {
@Override
public void metadataUpdated(Metadata metadata) {
- /* ignore. */
+ this.metadata = metadata;
}
@Override
}
@Override