import net.pterodactylus.fcp.ClientPutDiskDir;
import net.pterodactylus.fcp.Key;
+import net.pterodactylus.fcp.ProtocolError;
import net.pterodactylus.fcp.PutSuccessful;
import com.google.common.util.concurrent.ListeningExecutorService;
setResult(Optional.of(new Key(putSuccessful.getURI())));
}
+ @Override
+ protected void consumeProtocolError(ProtocolError protocolError) {
+ finish();
+ }
+
}
}