- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 316 for pubs (0.05 sec)
-
internal/pubsub/pubsub_test.go
t.Fatalf("unexpected error: %v", err) } if err := ps.Subscribe(MaskAll, ch2, doneCh, nil); err != nil { t.Fatalf("unexpected error: %v", err) } ps.Lock() defer ps.Unlock() if len(ps.subs) != 2 || ps.NumSubscribers(MaskAll) != 2 || ps.Subscribers() != 2 { t.Fatalf("expected 2 subscribers") } } func TestNumSubscribersMask(t *testing.T) { ps := New[Maskable, Mask](2) ch1 := make(chan Maskable, 1)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 5.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/helper.go
// versioned codecs, which use the external object for serialization but do not return it. func UnsafeObjectConvertor(scheme *Scheme) ObjectConvertor { return unsafeObjectConvertor{scheme} } // SetField puts the value of src, into fieldName, which must be a member of v. // The value of src must be assignable to the field. func SetField(src interface{}, v reflect.Value, fieldName string) error { field := v.FieldByName(fieldName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Dec 13 22:54:34 UTC 2023 - 8.4K bytes - Viewed (0) -
platforms/software/ivy/src/main/java/org/gradle/api/publish/ivy/IvyExtraInfoSpec.java
/** * Represents a modifiable form of IvyExtraInfo so that "extra" info elements * can be configured on an Ivy publication. */ public interface IvyExtraInfoSpec extends IvyExtraInfo { /** * Puts the specified extra element into the list of extra info elements. * * @param namespace The namespace of the element to add * @param name The name of the element to add
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 14:02:46 UTC 2023 - 1.2K bytes - Viewed (0) -
maven-jline/src/main/java/org/apache/maven/jline/FastTerminal.java
} @Override public String getType() { return getTerminal().getType(); } @Override public boolean puts(InfoCmp.Capability capability, Object... objects) { return getTerminal().puts(capability, objects); } @Override public boolean getBooleanCapability(InfoCmp.Capability capability) {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Apr 03 17:49:40 UTC 2024 - 6.7K bytes - Viewed (0) -
src/cmd/internal/codesign/codesign.go
func put64be(b []byte, x uint64) []byte { binary.BigEndian.PutUint64(b, x); return b[8:] } func put8(b []byte, x uint8) []byte { b[0] = x; return b[1:] } func puts(b, s []byte) []byte { n := copy(b, s); return b[n:] } // Size computes the size of the code signature. // id is the identifier used for signing (a field in CodeDirectory blob, which
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 29 14:23:19 UTC 2022 - 8.3K bytes - Viewed (0) -
pkg/registry/rbac/rolebinding/registry.go
// Registry is an interface for things that know how to store RoleBindings. type Registry interface { ListRoleBindings(ctx context.Context, options *metainternalversion.ListOptions) (*rbacv1.RoleBindingList, error) } // storage puts strong typing around storage calls type storage struct { rest.Lister } // NewRegistry returns a new Registry interface for the given Storage. Any mismatched // types will panic.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 22 12:17:05 UTC 2018 - 2.3K bytes - Viewed (0) -
src/io/fs/readfile_test.go
if string(data) != "hello, world" || err != nil { t.Fatalf(`ReadFile(openOnly, "hello.txt") = %q, %v, want %q, nil`, data, err, "hello, world") } // Test that ReadFile on Sub of . works (sub_test checks non-trivial subs). sub, err := Sub(testFsys, ".") if err != nil { t.Fatal(err) } data, err = ReadFile(sub, "hello.txt") if string(data) != "hello, world" || err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Nov 27 16:25:41 UTC 2023 - 1.8K bytes - Viewed (0) -
staging/src/k8s.io/client-go/applyconfigurations/core/v1/configmap.go
b.ensureObjectMetaApplyConfigurationExists() b.DeletionGracePeriodSeconds = &value return b } // WithLabels puts the entries into the Labels field in the declarative configuration // and returns the receiver, so that objects can be build by chaining "With" function invocations.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 23 17:59:55 UTC 2022 - 12.9K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/term/term.go
type State struct { state } // IsTerminal returns whether the given file descriptor is a terminal. func IsTerminal(fd int) bool { return isTerminal(fd) } // MakeRaw puts the terminal connected to the given file descriptor into raw // mode and returns the previous state of the terminal so that it can be // restored. func MakeRaw(fd int) (*State, error) { return makeRaw(fd) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 16 22:24:28 UTC 2022 - 1.8K bytes - Viewed (0) -
platforms/core-execution/hashing/src/main/java/org/gradle/internal/hash/Hasher.java
* Feed a string into the hasher. */ void putString(CharSequence value); /** * Feed a hash code into the hasher. */ void putHash(HashCode hashCode); /** * Puts a hashable value into the hasher. */ void put(Hashable hashable); /** * Feed a {@code null} value into the hasher. */ void putNull(); /** * Returns the combined hash.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Jan 11 11:14:18 UTC 2024 - 2.2K bytes - Viewed (0)