- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for nextEvent (0.39 sec)
-
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceRecorder.kt
val event = nextEvent() as Open return event.eventSource } fun assertClose() { nextEvent() as Closed } fun assertFailure(message: String?) { val event = nextEvent() as Failure if (message != null) { assertThat(event.t!!.message).isEqualTo(message) } else { assertThat(event.t).isNull() } } internal data class Open(
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketRecorder.kt
assertThat(nextEvent()).isEqualTo(Ping(payload)) } fun assertPong(payload: ByteString) { assertThat(nextEvent()).isEqualTo(Pong(payload)) } fun assertClosing( code: Int, reason: String, ) { assertThat(nextEvent()).isEqualTo(Closing(code, reason)) } fun assertClosed( code: Int, reason: String, ) {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6.9K bytes - Viewed (0) -
src/crypto/tls/quic.go
qs.events[last].Data[0] = 0 } if qs.nextEvent >= len(qs.events) && qs.waitingForDrain { qs.waitingForDrain = false <-qs.signalc <-qs.blockedc } if qs.nextEvent >= len(qs.events) { qs.events = qs.events[:0] qs.nextEvent = 0 return QUICEvent{Kind: QUICNoEvent} } e := qs.events[qs.nextEvent] qs.events[qs.nextEvent] = QUICEvent{} // zero out references to data qs.nextEvent++
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 17:23:54 UTC 2024 - 15.1K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/Dispatcher.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Dec 15 19:31:54 UTC 2023 - 7.3K bytes - Viewed (0) -
guava/src/com/google/common/eventbus/Dispatcher.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Dec 15 19:31:54 UTC 2023 - 7.3K bytes - Viewed (0) -
platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/registry/impl/DefaultFileWatcherRegistry.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 25 15:08:33 UTC 2024 - 11.2K bytes - Viewed (0) -
src/internal/trace/reader.go
} r.spillErr = err // Reset CPU samples cursor. r.cpuSamples = r.gen.cpuSamples // Reset frontier. for m, batches := range r.gen.batches { bc := &batchCursor{m: m} ok, err := bc.nextEvent(batches, r.gen.freq) if err != nil { return Event{}, err } if !ok { // Turns out there aren't actually any events in these batches. continue }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 6.7K bytes - Viewed (0) -
src/crypto/tls/quic_test.go
for _, c := range []*testQUICConn{a, b} { if !c.conn.conn.quic.started { if err := c.conn.Start(ctx); err != nil { return err } } } idleCount := 0 for { e := a.conn.NextEvent() if onEvent != nil && onEvent(e, a, b) { continue } switch e.Kind { case QUICNoEvent: idleCount++ if idleCount == 2 { if !a.complete || !b.complete {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 17:23:54 UTC 2024 - 19.3K bytes - Viewed (0) -
src/internal/trace/batchcursor.go
type batchCursor struct { m ThreadID lastTs Time idx int // next index into []batch dataOff int // next index into batch.data ev baseEvent // last read event } func (b *batchCursor) nextEvent(batches []batch, freq frequency) (ok bool, err error) { // Batches should generally always have at least one event, // but let's be defensive about that and accept empty batches.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 4.1K bytes - Viewed (0) -
api/go1.21.txt
pkg crypto/tls, method (*QUICConn) ConnectionState() ConnectionState #44886 pkg crypto/tls, method (*QUICConn) HandleData(QUICEncryptionLevel, []uint8) error #44886 pkg crypto/tls, method (*QUICConn) NextEvent() QUICEvent #44886 pkg crypto/tls, method (*QUICConn) SendSessionTicket(QUICSessionTicketOptions) error #60107 pkg crypto/tls, type QUICSessionTicketOptions struct #60107
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Aug 07 09:39:17 UTC 2023 - 25.6K bytes - Viewed (0)