- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 62 for sendZero (0.15 sec)
-
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/cmd/compile/internal/syntax/testdata/map.go
func (m *Map[K, V]) InOrder() *Iterator[K, V] { sender, receiver := chans.Ranger[keyValue[K, V]]() var f func(*node[K, V]) bool f = func(n *node[K, V]) bool { if n == nil { return true } // Stop sending values if sender.Send returns false, // meaning that nothing is listening at the receiver end. return f(n.left) && sender.Send(keyValue[K, V]{n.key, n.val}) && f(n.right) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 30 18:02:18 UTC 2022 - 2.8K bytes - Viewed (0) -
internal/s3select/csv/reader_contrib_test.go
fieldDelimiter: ",", sendErr: nil, header: true, wantColumns: []string{"header1", "header2", "header3"}, wantFields: "ok1,ok2,ok3\n" + `a word,"b"""` + "\n", wantErr: io.EOF, }, { // This works since LazyQuotes is true: file: "invalid-badstartline.csv", recordDelimiter: "\n", fieldDelimiter: ",", sendErr: nil,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 38.5K bytes - Viewed (0) -
src/crypto/internal/hpke/hpke.go
if err != nil { return nil, nil, err } return encapsulatedKey, &Sender{ kem: kem, aead: aead, sharedSecret: sharedSecret, suiteID: suiteID, key: key, baseNonce: baseNonce, exporterSecret: exporterSecret, }, nil } func (s *Sender) nextNonce() []byte { nonce := s.seqNum.bytes()[16-s.aead.NonceSize():]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:33:33 UTC 2024 - 7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/classpath/CallInterceptingMetaClass.java
} @Override public Object getProperty(Class sender, Object object, String name, boolean useSuper, boolean fromInsideClass) { if (useSuper || fromInsideClass) { return adaptee.getProperty(sender, object, name, useSuper, fromInsideClass); } else { return invokeIntercepted(object, GET_PROPERTY, name, NO_ARG, () -> adaptee.getProperty(sender, object, name, false, false)); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 13:46:35 UTC 2024 - 21.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/buffered/buffered.go
var sendErr error var evIndex int // If the delegateBackend was shutdown and the buffer channel was closed, an // attempt to add an event to it will result in panic that we should // recover from. defer func() { if err := recover(); err != nil { sendErr = fmt.Errorf("audit backend shut down") } if sendErr != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 9.1K bytes - Viewed (0) -
pkg/scheduler/framework/parallelize/error_channel.go
// again. type ErrorChannel struct { errCh chan error } // SendError sends an error without blocking the sender. func (e *ErrorChannel) SendError(err error) { select { case e.errCh <- err: default: } } // SendErrorWithCancel sends an error without blocking the sender and calls // cancel function. func (e *ErrorChannel) SendErrorWithCancel(err error, cancel context.CancelFunc) { e.SendError(err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 20 17:39:23 UTC 2021 - 1.6K bytes - Viewed (0) -
test/typeparam/orderedmap.go
return false } } } return true } // Ranger returns a Sender and a Receiver. The Receiver provides a // Next method to retrieve values. The Sender provides a Send method // to send values and a Close method to stop sending values. The Next // method indicates when the Sender has been closed, and the Send // method indicates when the Receiver has been freed. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 01 19:45:34 UTC 2022 - 7.1K bytes - Viewed (0) -
src/internal/bytealg/count_amd64.s
PCMPEQB X0, X1 PMOVMSKB X1, DX // Apply mask ANDQ R10, DX POPCNTL DX, DX ADDQ DX, R12 end: MOVQ R12, (R8) RET // handle for lengths < 16 small: TESTQ BX, BX JEQ endzero // Check if we'll load across a page boundary. LEAQ 16(SI), AX TESTW $0xff0, AX JEQ endofpage // We must ignore high bytes as they aren't part of our slice. // Create mask. MOVB BX, CX
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 06 20:54:43 UTC 2023 - 4.7K bytes - Viewed (0) -
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)