- Sort Score
- Num 10 results
- Language All
Results 151 - 160 of 1,056 for cend (0.02 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
docs/es/docs/tutorial/stream-json-lines.md
```mermaid sequenceDiagram participant App participant Client App->>App: Produce Item 1 App->>Client: Send Item 1 App->>App: Produce Item 2 Client->>Client: Process Item 1 App->>Client: Send Item 2 App->>App: Produce Item 3 Client->>Client: Process Item 2 App->>Client: Send Item 3 Client->>Client: Process Item 3 Note over App: Keeps producing... Note over Client: Keeps consuming...Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:12:26 GMT 2026 - 4.6K bytes - Click Count (0) -
docs/en/docs/tutorial/server-sent-events.md
{* ../../docs_src/server_sent_events/tutorial001_py310.py ln[28:31] hl[29] *} ### No Return Type { #no-return-type } You can also omit the return type. FastAPI will use the [`jsonable_encoder`](./encoder.md) to convert the data and send it. {* ../../docs_src/server_sent_events/tutorial001_py310.py ln[34:37] hl[35] *} ## `ServerSentEvent` { #serversentevent }Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 05 18:13:19 GMT 2026 - 4.6K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaBufferManager.java
log.warn("Failed to pre-allocate receive buffer", e); } } log.info("Initialized RDMA buffer pool with {} send and {} receive buffers", availableSendRegions.size(), availableReceiveRegions.size()); } /** * Get a send region from the pool or allocate a new one * * @param minSize minimum required size * @return memory region for sending
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 05:11:12 GMT 2025 - 8.7K bytes - Click Count (0) -
helm/minio/templates/service.yaml
{{- end }} spec: type: {{ .Values.service.type }} {{- if and (eq .Values.service.type "ClusterIP") .Values.service.clusterIP }} clusterIP: {{ .Values.service.clusterIP }} {{- end }} {{- if or (eq .Values.service.type "LoadBalancer") (eq .Values.service.type "NodePort") }} externalTrafficPolicy: {{ .Values.service.externalTrafficPolicy | quote }} {{- end }}Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Apr 28 10:05:53 GMT 2024 - 1.7K bytes - Click Count (0) -
helm/minio/templates/console-service.yaml
nodePort: {{ .Values.consoleService.nodePort }} {{- else }} targetPort: {{ .Values.minioConsolePort }} {{- end }} {{- if .Values.consoleService.externalIPs }} externalIPs: {{- range $i , $ip := .Values.consoleService.externalIPs }} - {{ $ip }} {{- end }} {{- end }} selector: app: {{ template "minio.name" . }}Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Apr 28 10:05:53 GMT 2024 - 1.8K bytes - Click Count (0) -
.github/workflows/notify-on-rc-for-manual-test.yml
run-name: Notify the IDE Experience team about new RCs for manual testing on: push: tags: - 'v*.*.*-RC1' permissions: {} jobs: send-slack-notification: runs-on: ubuntu-latest steps: - name: Send Slack notification about new RCs for manual testing id: slack uses: slackapi/slack-github-action@v3.0.1 with:Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Fri Mar 13 22:04:33 GMT 2026 - 912 bytes - Click Count (0) -
src/main/java/jcifs/smb1/smb1/SmbTree.java
@Override public boolean equals(final Object obj) { if (obj instanceof final SmbTree tree) { return matches(tree.share, tree.service); } return false; } void send(final ServerMessageBlock request, final ServerMessageBlock response) throws SmbException { synchronized (session.transport()) { if (response != null) { response.received = false; }Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 07:14:38 GMT 2025 - 8.1K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/WebSocket.kt
* its incoming messages. * * ## Message Queue * * Messages enqueued with [send] are buffered in an outgoing message queue. This queue has a 16 MiB * limit. If a call to [send] would cause the queue to exceed this limit, the web socket will * initiate a graceful shutdown (close code 1001) and `send()` will return `false`. No exception is
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Mar 10 21:45:14 GMT 2026 - 6.1K bytes - Click Count (0) -
tests/test_stream_cancellation.py
# Simulate a client that never disconnects, rely on cancellation await anyio.sleep(float("inf")) return {"type": "http.disconnect"} # pragma: no cover async def send(message: dict) -> None: # type: ignore[type-arg] if message["type"] == "http.response.body": chunks.append(message.get("body", b"")) scope = { "type": "http",Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Feb 27 18:56:47 GMT 2026 - 2.7K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbEnumerationUtil.java
final SmbComTransaction req = new NetShareEnum(th.getConfig()); final SmbComTransactionResponse resp = new NetShareEnumResponse(th.getConfig()); th.send(req, resp); if (resp.getStatus() != WinError.ERROR_SUCCESS) { throw new SmbException(resp.getStatus(), true); } return resp.getResults(); }
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 07:14:38 GMT 2025 - 12.3K bytes - Click Count (0)