}
	return nil, err
}

func (s *serializer) Decode(data []byte, gvk *schema.GroupVersionKind, into runtime.Object) (runtime.Object, *schema.GroupVersionKind, error) {
	// A preliminary pass over the input to obtain the actual GVK is redundant on a successful
	// decode into Unstructured.
	if _, ok := into.(runtime.Unstructured); ok {

				if err := jsonSerializer.Encode(item, &buf); err != nil {
					t.Fatalf("error encoding native to json: %v", err)
				}
				var uJSON runtime.Object = &metaunstruct.Unstructured{}
				uJSON, _, err = jsonSerializer.Decode(buf.Bytes(), &gvk, uJSON)
				if err != nil {
					t.Fatalf("error decoding json to unstructured: %v", err)
				}

				// original->CBOR->Unstructured
				buf.Reset()

        val javaClass = GeneratedSubclasses.unpackType(value)
        writeClass(javaClass)
        logNotImplemented(javaClass)
    }

    override suspend fun ReadContext.decode(): Any? {
        logNotImplemented(readClass())
        return null
    }

object LevelCodec : Codec<Level> {

    override suspend fun WriteContext.encode(value: Level) {
        encodeUsingJavaSerialization(value)
    }

    override suspend fun ReadContext.decode(): Level? =
        decodeUsingJavaSerialization()?.uncheckedCast()

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
    }

	// Trimming leading and tailing white spaces.
	data = bytes.TrimSpace(data)

	// Parse all certs in the chain.
	current := data
	for len(current) > 0 {
		var pemBlock *pem.Block
		if pemBlock, current = pem.Decode(current); pemBlock == nil {
			return nil, ErrTLSUnexpectedData(nil).Msg("Could not read PEM block from file %s", certFile)
		}

		var x509Cert *x509.Certificate

        // to work around https://bugs.openjdk.java.net/browse/JDK-8054978
        // on Java 8
        writeLong(value.seconds)
        writeSmallInt(value.nano)
    }

    override suspend fun ReadContext.decode(): Duration =
        Duration.ofSeconds(readLong(), readSmallInt().toLong())

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)