*/
        boolean isResolved();

        /**
         * Indicates whether the requested artifact is not present in any of the specified repositories.
         *
         * @return {@code true} if the artifact is not present in any repository, {@code false} otherwise.
         */
        boolean isMissing();
    }

     * </ul>
     */
    private static boolean validateNotNull(
            SettingsProblemCollector problems, String fieldName, Object object, String sourceHint) {
        if (object != null) {
            return true;
        }

        addViolation(problems, Severity.ERROR, fieldName, sourceHint, "is missing");

        return false;
    }

    private static boolean validateBannedCharacters(

    @SuppressWarnings("ThreadLocalUsage") // Each Dispatcher needs its own state.
    private final ThreadLocal<Boolean> dispatching =
        new ThreadLocal<Boolean>() {
          @Override
          protected Boolean initialValue() {
            return false;
          }
        };

    @Override
    void dispatch(Object event, Iterator<Subscriber> subscribers) {

        private final DataStoreParams initParamMap;

        /** Flag indicating whether the crawling thread has finished execution */
        protected boolean finished = false;

        /** Flag indicating whether the crawling thread is currently running */
        protected boolean running = false;

        /** The data store instance used for crawling operations */
        private DataStore dataStore;

        /**

		}
		return FromFloat(*e.Int), nil
	case e.Float != nil:
		return FromFloat(*e.Float), nil
	case e.String != nil:
		return FromString(string(*e.String)), nil
	case e.Boolean != nil:
		return FromBool(bool(*e.Boolean)), nil
	case e.Missing:
		return FromMissing(), nil
	}
	return FromNull(), nil

            throw new StorageException("Failed to download " + objectName, e);
        }
    }

    @Override
    public void deleteObject(final String objectName) {
        try {
            final boolean deleted = storage.delete(BlobId.of(bucket, objectName));
            if (!deleted && logger.isDebugEnabled()) {
                logger.debug("Object may not exist: {}", objectName);
            }

 * This class is not thread safe.
 *
 * [rfc_6455]: http://tools.ietf.org/html/rfc6455
 */
class WebSocketReader(
  private val isClient: Boolean,
  val source: BufferedSource,
  private val frameCallback: FrameCallback,
  private val perMessageDeflate: Boolean,
  private val noContextTakeover: Boolean,
) : Closeable {
  private var closed = false
  private var receivedCloseFrame = false

  // Stateful data about the current frame.

                }
            }
        }

        return value;
    }

    private static boolean isTypeCompatible(Class<?> type, Object value) {
        if (type.isInstance(value)) {
            return true;
        }
        // likely Boolean -> boolean, Short -> int etc. conversions, it's not the problem case we try to avoid

    @GwtIncompatible @J2ktIncompatible     private static final long serialVersionUID = 0x150ddL;

    @Override
    public boolean apply(@Nullable Integer i) {
      return (i.intValue() & 1) == 1;
    }

    @Override
    public int hashCode() {
      return 0x150dd;
    }

    @Override
    public boolean equals(@Nullable Object obj) {
      return obj instanceof IsOdd;
    }

    @Override

 * it's easy to get one: `converter::convert`.
 *
 * [*] In annotating this class, we're ignoring LegacyConverter.
 */
public abstract class Converter<A, B> implements Function<A, B> {
  private final boolean handleNullAutomatically;

  // We lazily cache the reverse view to avoid allocating on every call to reverse().
  @LazyInit @RetainedWith private transient @Nullable Converter<B, A> reverse;