Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 8 of 8 for recordedEventTypes (0.11 seconds)

  1. okhttp/src/jvmTest/kotlin/okhttp3/internal/tls/ClientAuthTest.kt

        val recordedEventTypes = eventRecorder.recordedEventTypes()
        assertThat(recordedEventTypes).startsWith(
          CallStart::class,
          ProxySelectStart::class,
          ProxySelectEnd::class,
          DnsStart::class,
          DnsEnd::class,
          ConnectStart::class,
          SecureConnectStart::class,
        )
        assertThat(recordedEventTypes).endsWith(CallFailed::class)
      }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 13K bytes
    - Click Count (0)
  2. okhttp-testing-support/src/main/kotlin/okhttp3/EventRecorder.kt

          assertThat(
            TimeUnit.NANOSECONDS
              .toMillis(actualElapsedNs)
              .toDouble(),
          ).isCloseTo(elapsedMs.toDouble(), 100.0)
        }
    
        return result
      }
    
      fun recordedEventTypes() = eventSequence.map { it::class }
    
      fun clearAllEvents() {
        while (eventSequence.isNotEmpty()) {
          takeEvent()
        }
      }
    
      internal fun logEvent(e: CallEvent) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 4.5K bytes
    - Click Count (0)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt

          assertThat(
            TimeUnit.NANOSECONDS
              .toMillis(actualElapsedNs)
              .toDouble(),
          ).isCloseTo(elapsedMs.toDouble(), 100.0)
        }
    
        return result
      }
    
      fun recordedEventTypes() = eventSequence.map { it.name }
    
      fun clearAllEvents() {
        while (eventSequence.isNotEmpty()) {
          takeEvent()
        }
      }
    
      private fun logEvent(e: ConnectionEvent) {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 5.8K bytes
    - Click Count (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt

          )
        val response = call.execute()
        assertThat(response.code).isEqualTo(200)
        assertThat(response.body.string()).isEqualTo("abc")
        response.body.close()
        assertThat(eventRecorder.recordedEventTypes()).containsExactly(
          CallStart::class,
          ProxySelectStart::class,
          ProxySelectEnd::class,
          DnsStart::class,
          DnsEnd::class,
          ConnectStart::class,
          ConnectEnd::class,
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 70.7K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/http/HttpUpgradesTest.kt

          assertThat(response.body.string()).isEqualTo("normal request")
        }
        // Confirm there's no RequestBodyStart/RequestBodyEnd on failed upgrades.
        assertThat(eventRecorder.recordedEventTypes()).containsExactly(
          CallStart::class,
          ProxySelectStart::class,
          ProxySelectEnd::class,
          DnsStart::class,
          DnsEnd::class,
          ConnectStart::class,
          ConnectEnd::class,
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 08 21:07:01 GMT 2026
    - 9.7K bytes
    - Click Count (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/ServerTruncatesRequestTest.kt

        expectedEvents += ResponseBodyStart::class
        expectedEvents += ResponseBodyEnd::class
        expectedEvents += ConnectionReleased::class
        expectedEvents += CallEnd::class
        assertThat(eventRecorder.recordedEventTypes()).isEqualTo(expectedEvents)
    
        // Confirm that the connection pool was not corrupted by making another call.
        makeSimpleCall()
      }
    
      /**
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Jan 11 11:54:15 GMT 2026
    - 10.7K bytes
    - Click Count (0)
  7. android-test/src/androidDeviceTest/java/okhttp/android/test/OkHttpTest.kt

            FollowUpDecision::class,
            ResponseBodyStart::class,
            ResponseBodyEnd::class,
            ConnectionReleased::class,
            CallEnd::class,
          ),
          eventRecorder.recordedEventTypes(),
        )
    
        eventRecorder.clearAllEvents()
    
        client.newCall(request).execute().use { response ->
          assertEquals(200, response.code)
        }
    
        assertEquals(
          listOf(
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 29.9K bytes
    - Click Count (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

          client.newCall(request2).execute()
        }.also { expected ->
          assertThat(expected.message!!).startsWith("unexpected end of stream on http://")
        }
    
        assertThat(eventRecorder.recordedEventTypes()).containsExactly(
          CallStart::class,
          ConnectionAcquired::class,
          RequestHeadersStart::class,
          RequestHeadersEnd::class,
          RequestBodyStart::class,
          RequestBodyEnd::class,
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:02:18 GMT 2026
    - 146.5K bytes
    - Click Count (0)
Back to Top