- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for onRequest (0.15 sec)
-
staging/src/k8s.io/apiserver/plugin/pkg/audit/fake/fake.go
// ProcessEvents calls a callback on a batch, if present. func (b *Backend) ProcessEvents(ev ...*auditinternal.Event) bool { if b.OnRequest != nil { b.OnRequest(ev) } return true } func (b *Backend) String() string { return ""
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 16 09:32:49 UTC 2018 - 1.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/PushObserver.kt
* Implementations must quickly dispatch callbacks to avoid creating a bottleneck. * * While [onReset] may occur at any time, the following callbacks are expected in order, * correlated by stream ID. * * * [onRequest] * * [onHeaders] (unless canceled) * * [onData] (optional sequence of data frames) * * As a stream ID is scoped to a single HTTP/2 connection, implementations which target multiple
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.6K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/FaultTolerantClient.java
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 4.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/truncate/truncate_test.go
wantDropped: true, }, } for _, tc := range testCases { tc := tc t.Run(tc.desc, func(t *testing.T) { t.Parallel() var event *auditinternal.Event fb := &fake.Backend{ OnRequest: func(events []*auditinternal.Event) { require.Equal(t, 1, len(events), "Expected single event in batch") event = events[0] }, } b := NewBackend(fb, defaultConfig, auditv1.SchemeGroupVersion)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 30 07:56:39 UTC 2018 - 3.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/buffered/buffered_test.go
func TestBufferedBackendShutdownWaitsForDelegatedCalls(t *testing.T) { t.Parallel() delegatedCallStartCh := make(chan struct{}) delegatedCallEndCh := make(chan struct{}) delegateBackend := &fake.Backend{ OnRequest: func(_ []*auditinternal.Event) { close(delegatedCallStartCh) <-delegatedCallEndCh }, } config := testBatchConfig() backend := NewBackend(delegateBackend, config)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 14 17:20:35 UTC 2018 - 5.9K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/duplex/MockStreamHandler.kt
} } /** Returns once all stream actions complete successfully. */ fun awaitSuccess() { val futureTask = results.poll(5, TimeUnit.SECONDS) ?: throw AssertionError("no onRequest call received") futureTask.get(5, TimeUnit.SECONDS) }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.2K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/FaultTolerantClientTest.java
@Override public void onRequestStart(final FaultTolerantClient client, final RequestData request) { startCount++; } @Override public void onRequest(final FaultTolerantClient client, final RequestData request, final int count) { requestCount++; requestUrl = request.getUrl(); requestMethod = request.getMethod().toString(); }
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 15.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
writeSynResetLater(streamId, ErrorCode.PROTOCOL_ERROR) return } currentPushRequests.add(streamId) } pushQueue.execute("$connectionName[$streamId] onRequest") { val cancel = pushObserver.onRequest(streamId, requestHeaders) ignoreIoExceptions { if (cancel) { writer.rstStream(streamId, ErrorCode.CANCEL) this.withLock {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0) -
internal/grid/msg_string.go
_ = x[OpDisconnectClientMux-7] _ = x[OpDisconnectServerMux-8] _ = x[OpMuxClientMsg-9] _ = x[OpMuxServerMsg-10] _ = x[OpUnblockSrvMux-11] _ = x[OpUnblockClMux-12] _ = x[OpAckMux-13] _ = x[OpRequest-14] _ = x[OpResponse-15] _ = x[OpDisconnect-16] _ = x[OpMerged-17] }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 1.2K bytes - Viewed (0)