assertThat(responseA.body.string()).isEqualTo("a")
            }
            chain.proceed(chain.request())
          },
        ).build()
    val requestB =
      Request
        .Builder()
        .url(server.url("/b"))
        .build()
    val responseB = client.newCall(requestB).execute()
    assertThat(responseB.body.string()).isEqualTo("b")
  }

      builder.append(", setFuture=[");
      appendUserObject(builder, ((DelegatingToFuture) localValue).future);
      builder.append("]");
    } else {
      String pendingDescription;
      try {
        pendingDescription = Strings.emptyToNull(pendingToString());
      } catch (Throwable e) {
        /*
         * We want to catch (Exception | StackOverflowError), but we can't under environments where

 *
 * [rfc_2046]: http://www.ietf.org/rfc/rfc2046.txt
 */
class MultipartReader
  @Throws(IOException::class)
  constructor(
    private val source: BufferedSource,
    @get:JvmName("boundary") val boundary: String,
  ) : Closeable {
    /** This delimiter typically precedes the first part. */
    private val dashDashBoundary =
      Buffer()
        .writeUtf8("--")
        .writeUtf8(boundary)
        .readByteString()

    class BasicFunctionalityTests {

        @Test
        @DisplayName("toString should return meaningful representation")
        void shouldReturnMeaningfulToString() {
            String result = transport.toString();
            assertTrue(result.startsWith("Transport"));
            assertFalse(result.isEmpty());
        }

        @Test

    val buffer = Buffer()
    body.writeTo(buffer)
    assertThat(buffer.readUtf8()).isEqualTo(expected)
  }

  @Test
  fun streamingPartHasNoLength() {
    class StreamingBody(
      private val body: String,
    ) : RequestBody() {
      override fun contentType(): MediaType? = null

      @Throws(IOException::class)
      override fun writeTo(sink: BufferedSink) {
        sink.writeUtf8(body)
      }
    }

    void testToStringWithAces() throws SMBProtocolDecodingException {
        prepareSecurityDescriptorBufferWithDACL(testBuffer, 0, 2);

        securityDescriptor.decode(testBuffer, 0, testBuffer.length);

        String result = securityDescriptor.toString();
        assertNotNull(result);
        assertTrue(result.startsWith("SecurityDescriptor:"));
        assertFalse(result.contains("NULL"));
    }

    @Test

      <span style="background-color:#007166"><font color="#D3D7CF"> app </font></span>  Using import string: <font color="#3465A4">main:app</font>

    this.executorServiceOrNull = executorService
  }

  internal fun enqueue(call: AsyncCall) {
    promoteAndExecute(enqueuedCall = call)
  }

  private fun findExistingCallWithHost(host: String): AsyncCall? {
    for (existingCall in runningAsyncCalls) {
      if (existingCall.host == host) return existingCall
    }
    for (existingCall in readyAsyncCalls) {

        assertTrue(result > 0);
        assertNotNull(response.getSecurityDescriptor());
    }

    @Test
    @DisplayName("Test toString returns expected format")
    void testToString() {
        String result = response.toString();

        assertNotNull(result);
        assertTrue(result.startsWith("NtTransQuerySecurityResponse["));
        assertTrue(result.endsWith("]"));
    }

    @Test

      <span style="background-color:#007166"><font color="#D3D7CF"> app </font></span>  Using import string: <font color="#3465A4">main:app</font>