import org.gradle.internal.serialize.graph.WriteContext


object UnitCodec : Codec<Unit> {

    override suspend fun WriteContext.encode(value: Unit) {
        // noop
    }

    override suspend fun ReadContext.decode() {
        // returns Unit instance under the hood
    }

object ClassCodec : Codec<Class<*>> {

    override suspend fun WriteContext.encode(value: Class<*>) {
        writeClass(value)
    }

    override suspend fun ReadContext.decode(): Class<*>? =
        readClass()

			retryBackoffTime *= 2 // Exponentially increase the retry backoff time.
		}
		defer resp.Body.Close()

		doc := new(bundleDoc)
		if err := json.NewDecoder(resp.Body).Decode(doc); err != nil {
			return nil, fmt.Errorf("trust domain [%s] at URL [%s] failed to decode bundle: %v", trustDomain, endpoint, err)
		}

		var certs []*x509.Certificate
		for i, key := range doc.Keys {
			if key.Use == "x509-svid" {

    override suspend fun WriteContext.encode(value: DestinationRootCopySpec) {
        write(value.destinationDir)
        write(value.delegate)
    }

    override suspend fun ReadContext.decode(): DestinationRootCopySpec {
        val destDir = read() as? File
        val delegate = read() as CopySpecInternal
        val spec = DestinationRootCopySpec(fileResolver, delegate)
        destDir?.let(spec::into)

object ImmutableMapCodec : Codec<ImmutableMap<Any, Any>> {

    override suspend fun WriteContext.encode(value: ImmutableMap<Any, Any>) {
        writeMap(value)
    }

    override suspend fun ReadContext.decode(): ImmutableMap<Any, Any>? {
        val size = readSmallInt()
        val builder = ImmutableMap.builderWithExpectedSize<Any, Any>(size)
        for (i in 0 until size) {
            val key = read()!!

import org.slf4j.LoggerFactory


object LoggerCodec : Codec<Logger> {

    override suspend fun WriteContext.encode(value: Logger) {
        writeString(value.name)
    }

    override suspend fun ReadContext.decode(): Logger? =
        LoggerFactory.getLogger(readString())

import java.nio.charset.Charset


object CharsetCodec : Codec<Charset> {

    override suspend fun WriteContext.encode(value: Charset) {
        writeString(value.name())
    }

    override suspend fun ReadContext.decode(): Charset =
        Charset.forName(readString())

import java.net.URL


object UrlCodec : Codec<URL> {

    override suspend fun WriteContext.encode(value: URL) {
        writeString(value.toExternalForm())
    }

    override suspend fun ReadContext.decode(): URL =
        URL(readString())

            String daemonRegistryDir = matcher.group(4);
            String pidStr = matcher.group(5);
            Long pid = pidStr.equals("null") ? null : Long.parseLong(pidStr);
            Integer idleTimeout = Integer.decode(matcher.group(6));
            DaemonParameters.Priority priority = matcher.group(7) == null ? DaemonParameters.Priority.NORMAL : DaemonParameters.Priority.valueOf(matcher.group(7).substring(",priority=".length()));

) : Codec<ActionNode> {
    override suspend fun WriteContext.encode(value: ActionNode) {
        withCodec(userTypesCodec) {
            write(value.action)
        }
    }

    override suspend fun ReadContext.decode(): ActionNode {
        val action = withCodec(userTypesCodec) { readNonNull<WorkNodeAction>() }
        return ActionNode(action)
    }