// until link time (e.g. gostrings).

package main

import (
	"fmt"
)

type T struct {
	x [4]byte
	y [8]byte
}

var st T

const (
	gostring1 = "abc"
	gostring2 = "defghijk"
	gostring3 = "lmnopqrs"
)

func f(a T, _ byte, b T) bool {
	// initialization of a,b
	// tests unaligned store
	return a.y == b.y
}

func g(a T) {
	// test load of unaligned

			flags: map[string]string{
				options.TokenStr:                 "aaaaaa.0123456789aaaaaa",
				options.TLSBootstrapToken:        "abcdef.0123456789abcdef",
				options.TokenDiscovery:           "defghi.0123456789defghi",
				options.TokenDiscoverySkipCAHash: "true",
			},
			validate: func(t *testing.T, data *joinData) {
				// validate that TLSBootstrapToken and BootstrapToken.Token values are preserved into join data

        def instr = new DisconnectableInputStream(source, toActionExecuter(executorFactory), 10)

        run {
            syncAt(1)
            assertReads(instr, 'abc')
            assertReads(instr, 'defghi')
            assertReads(instr, 'j')
        }

        instr.close()
    }

    @Test
    void readerThreadStopsReadingAfterClose() {
        def source = stream()

        .bodyDelay(responseBodyStartDelay, TimeUnit.MILLISECONDS)
        .throttleBody(5, responseBodyEndDelay, TimeUnit.MILLISECONDS)
        .body("fghijk")
        .build(),
    )
    call.execute().use { response ->
      assertThat(response.body.string()).isEqualTo("fghijk")
    }

    // Confirm the events occur when expected.
    listener.takeEvent(CallStart::class.java, 0L)