projects
/
sonitus.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Move event and metadata handling into abstract base class.
[sonitus.git]
/
src
/
main
/
java
/
net
/
pterodactylus
/
sonitus
/
data
/
Pipeline.java
diff --git
a/src/main/java/net/pterodactylus/sonitus/data/Pipeline.java
b/src/main/java/net/pterodactylus/sonitus/data/Pipeline.java
index
ee67eec
..
c24502f
100644
(file)
--- a/
src/main/java/net/pterodactylus/sonitus/data/Pipeline.java
+++ b/
src/main/java/net/pterodactylus/sonitus/data/Pipeline.java
@@
-335,8
+335,6
@@
public class Pipeline implements Iterable<ControlledComponent> {
Metadata firstMetadata = null;
while (!stopped.get()) {
try {
Metadata firstMetadata = null;
while (!stopped.get()) {
try {
- final Metadata lastMetadata = firstMetadata;
- final Metadata metadata = firstMetadata = source.metadata();
final byte[] buffer;
try {
logger.finest(String.format("Getting %d bytes from %s...", 4096, source));
final byte[] buffer;
try {
logger.finest(String.format("Getting %d bytes from %s...", 4096, source));
@@
-353,9
+351,6
@@
public class Pipeline implements Iterable<ControlledComponent> {
@Override
public Void call() throws Exception {
@Override
public Void call() throws Exception {
- if (!metadata.equals(lastMetadata)) {
- sink.metadataUpdated(metadata);
- }
try {
logger.finest(String.format("Sending %d bytes to %s.", buffer.length, sink));
sink.process(buffer);
try {
logger.finest(String.format("Sending %d bytes to %s.", buffer.length, sink));
sink.process(buffer);