- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 128 for bsender (0.18 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
* that trigger this are HEADERS and PUSH_PROMISE. * * @param inFinished true if the sender will not send further frames. * @param streamId the stream owning these headers. * @param associatedStreamId the stream that triggered the sender to create this stream. */ fun headers( inFinished: Boolean, streamId: Int, associatedStreamId: Int,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 19.9K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/EmlExtractor.java
putValue(data, "Message-Number", message.getMessageNumber()); putValue(data, "Received-Date", getReceivedDate(message)); putValue(data, "Reply-To", message.getReplyTo()); putValue(data, "Sender", message.getSender()); putValue(data, "Sent-Date", message.getSentDate()); putValue(data, "Size", message.getSize()); putValue(data, "Subject", message.getSubject());
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 10.8K bytes - Viewed (0) -
src/net/http/internal/chunked_test.go
if _, err := io.ReadAll(r); err != readErr { t.Errorf("expected %v, got %v", readErr, err) } } func TestChunkReaderTooMuchOverhead(t *testing.T) { // If the sender is sending 100x as many chunk header bytes as chunk data, // we should reject the stream at some point. chunk := []byte("1;") for i := 0; i < 100; i++ { chunk = append(chunk, 'a') // chunk extension }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jan 04 20:45:19 UTC 2024 - 8K bytes - Viewed (0) -
internal/grid/msg.go
m.Flags &^= FlagPayloadIsZero if len(m.Payload) == 0 && m.Payload != nil { m.Flags |= FlagPayloadIsZero } } type receiver interface { msgp.Unmarshaler Op() Op } type sender interface { msgp.MarshalSizer Op() Op } type connectReq struct { ID [16]byte Host string } func (connectReq) Op() Op { return OpConnect } type connectResp struct {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Nov 28 19:22:29 UTC 2023 - 7.3K bytes - Viewed (0) -
docs/de/docs/advanced/websockets.md
## Nachrichten erwarten und Nachrichten senden In Ihrer WebSocket-Route können Sie Nachrichten `await`en und Nachrichten senden. ```Python hl_lines="48-52" {!../../../docs_src/websockets/tutorial001.py!} ``` Sie können Binär-, Text- und JSON-Daten empfangen und senden. ## Es ausprobieren Wenn Ihre Datei `main.py` heißt, führen Sie Ihre Anwendung so aus:
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Mar 30 20:17:58 UTC 2024 - 6.9K bytes - Viewed (0) -
docs/pt/docs/tutorial/schema-extra-example.md
``` Essas informações extras serão adicionadas como se encontram no **JSON Schema** de resposta desse modelo e serão usadas na documentação da API. !!! tip "Dica" Você pode usar a mesma técnica para estender o JSON Schema e adicionar suas próprias informações extras de forma personalizada. Por exemplo, você pode usar isso para adicionar metadados para uma interface de usuário de front-end, etc.
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Fri Mar 22 01:42:11 UTC 2024 - 6.1K bytes - Viewed (0) -
test/closedchan.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. // Test close(c), receive of closed channel. // // TODO(rsc): Doesn't check behavior of close(c) when there // are blocked senders/receivers. package main import "os" var failed bool type Chan interface { Send(int) Nbsend(int) bool Recv() (int) Nbrecv() (int, bool) Recv2() (int, bool)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 17 04:48:57 UTC 2012 - 5.8K bytes - Viewed (0) -
internal/grid/muxserver.go
go func() { wg.Wait() defer xioutil.SafeClose(send) err := m.handleRequests(ctx, msg, send, handler, handlerIn) if err != nil { handlerErr.Store(err) } }() // Response sender goroutine... go func(outBlock <-chan struct{}) { wg.Wait() defer m.parent.deleteMux(true, m.ID) m.sendResponses(ctx, send, c, &handlerErr, outBlock) }(m.outBlock) // Remote aliveness check if needed.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_cluster_util.cc
} return frame_id; }; for (Edge const* edge : graph->edges()) { if (edge->dst()->IsEnter() || edge->src()->IsExit()) { const char* src_type = "pre-enter"; const char* dst_type = "post-exit"; int src = edge->src()->id(); int dst = edge->dst()->id(); if (edge->dst()->IsEnter()) { // Lift edges to an "Enter" node to the corresponding frame node.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 29 08:39:39 UTC 2024 - 21.3K bytes - Viewed (0) -
cmd/admin-handlers-users.go
return } } // Check if we are creating svc account for request sender. isSvcAccForRequestor := false if targetUser == requestorUser || targetUser == requestorParentUser { isSvcAccForRequestor = true } // If we are creating svc account for request sender, ensure // that targetUser is a real user (i.e. not derived // credentials). if isSvcAccForRequestor {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 28 17:19:04 UTC 2024 - 78.6K bytes - Viewed (0)