- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 128 for bsender (0.43 sec)
-
src/runtime/race/testdata/chan_test.go
_ = data[i] } } // Test that sender synchronizes with receiver even if the sender was blocked. func TestNoRaceBlockedSendSync(t *testing.T) { c := make(chan *int, 1) c <- nil go func() { i := 42 c <- &i }() // Give the sender time to actually block. // This sleep is completely optional: race report must not be printed // regardless of whether the sender actually blocks or not.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 18 19:55:29 UTC 2023 - 11K bytes - Viewed (0) -
docs/de/docs/advanced/events.md
{!../../../docs_src/events/tutorial003.py!} ``` Der erste Teil der Funktion, vor dem `yield`, wird ausgeführt **bevor** die Anwendung startet. Und der Teil nach `yield` wird ausgeführt, **nachdem** die Anwendung beendet ist. ### Asynchroner Kontextmanager Wie Sie sehen, ist die Funktion mit einem `@asynccontextmanager` versehen. Dadurch wird die Funktion in einen sogenannten „**asynchronen Kontextmanager**“ umgewandelt.
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Mar 30 20:30:59 UTC 2024 - 9.1K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/model/internal/registry/UnboundRulesProcessor.java
public List<? extends UnboundRule> process() { List<UnboundRule> unboundRules = new ArrayList<UnboundRule>(); for (RuleBinder binder : binders) { UnboundRule.Builder builder = UnboundRule.descriptor(String.valueOf(binder.getDescriptor())); ModelBinding subjectBinding = binder.getSubjectBinding(); // Only report subject binding if target state is after node creation
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Sep 28 09:51:04 UTC 2023 - 3.5K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/internal/classpath/CallInterceptingMetaClassTest.groovy
"invokeMethod(sender, receiver, methodName, arguments, false, false)" | { instance.metaClass.invokeMethod(getClass(), instance, "test", [].toArray(), false, false) } | true | false // These should not be intercepted because of isCallToSuper and fromInsideClass
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Nov 24 13:33:59 UTC 2023 - 15K bytes - Viewed (0) -
src/net/http/internal/chunked.go
if cr.err != nil { return } cr.n, cr.err = parseHexUint(line) if cr.err != nil { return } // A sender who sends one byte per chunk will send 5 bytes of overhead // for every byte of data. ("1\r\nX\r\n" to send "X".) // We want to allow this, since streaming a byte at a time can be legitimate. // // A sender can use chunk extensions to add arbitrary amounts of additional
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 7.8K bytes - Viewed (0) -
releasenotes/notes/39699.yaml
# release notes. releaseNotes: - | **Improved** compatibility with minimal host OSses like Talos OS (without nsenter binary). Changes Network namespaces with internal go routines.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jul 15 15:18:33 UTC 2022 - 1.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Settings.kt
const val MAX_CONCURRENT_STREAMS = 4 /** HTTP/2: Size in bytes of the largest frame payload the sender will accept. */ const val MAX_FRAME_SIZE = 5 /** HTTP/2: Advisory only. Size in bytes of the largest header list the sender will accept. */ const val MAX_HEADER_LIST_SIZE = 6 /** Window size in bytes. */ const val INITIAL_WINDOW_SIZE = 7
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.8K bytes - Viewed (0) -
src/compress/gzip/example_test.go
go func() { defer close(errch) sentErr := false sendErr := func(err error) { if !sentErr { errch <- err sentErr = true } } // Copy our data to gzipWriter, which compresses it to // gzipWriter, which feeds it to bodyReader. if _, err := io.Copy(gzipWriter, dataReader); err != nil && err != io.ErrClosedPipe { sendErr(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 22 16:24:14 UTC 2022 - 4.8K bytes - Viewed (0) -
src/main/resources/fess_message_de.properties
errors.document_not_found=URL der Dokument-ID nicht gefunden: {0} errors.not_load_from_server=Konnte nicht vom Server geladen werden: {0} errors.failed_to_start_job=Start der Aufgabe {0} fehlgeschlagen. errors.failed_to_stop_job=Beenden der Aufgabe {0} fehlgeschlagen. errors.failed_to_download_synonym_file=Download der Synonym-Datei fehlgeschlagen. errors.failed_to_upload_synonym_file=Upload der Synonym-Datei fehlgeschlage.
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Tue Oct 29 15:01:03 UTC 2019 - 11.8K bytes - Viewed (0) -
src/runtime/chan.go
} return true, false } // The channel has been closed, but the channel's buffer have data. } else { // Just found waiting sender with not closed. if sg := c.sendq.dequeue(); sg != nil { // Found a waiting sender. If buffer is size 0, receive value // directly from sender. Otherwise, receive from head of queue // and add sender's value to the tail of the queue (both map to
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:50 UTC 2024 - 25.9K bytes - Viewed (0)