- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for GetResponse (0.16 sec)
-
guava-tests/test/com/google/common/util/concurrent/TestThread.java
assertEquals(null, getResponse(methodName).getResult()); } /** * Asserts that a prior call that had caused this thread to block or wait has since returned the * expected boolean value. */ public void assertPriorCallReturns(boolean expected, @Nullable String methodName) throws Exception { assertEquals(expected, getResponse(methodName).getResult()); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 10.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestThread.java
assertEquals(null, getResponse(methodName).getResult()); } /** * Asserts that a prior call that had caused this thread to block or wait has since returned the * expected boolean value. */ public void assertPriorCallReturns(boolean expected, @Nullable String methodName) throws Exception { assertEquals(expected, getResponse(methodName).getResult()); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 10.8K bytes - Viewed (0) -
platforms/core-runtime/daemon-protocol/src/main/java/org/gradle/launcher/daemon/protocol/UserResponse.java
*/ public class UserResponse extends InputMessage { private final String response; public UserResponse(String response) { this.response = response; } public String getResponse() { return response; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 04:50:46 UTC 2024 - 1005 bytes - Viewed (0) -
pkg/config/validation/virtualservice.go
errs = AppendValidation(errs, ValidateHTTPHeaderOperationName(name)) } for name, val := range http.Headers.GetResponse().GetAdd() { errs = AppendValidation(errs, ValidateHTTPHeaderOperationName(name)) errs = AppendValidation(errs, ValidateHTTPHeaderValue(val)) } for name, val := range http.Headers.GetResponse().GetSet() { errs = AppendValidation(errs, ValidateHTTPHeaderOperationName(name))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 04:03:27 UTC 2024 - 9.3K bytes - Viewed (0) -
platforms/core-runtime/daemon-services/src/main/java/org/gradle/internal/daemon/clientinput/ClientInputForwarder.java
} @Override public void onUserResponse(UserResponse input) { inputReader.putInput(new UserInputReader.TextResponse(input.getResponse())); } @Override public void onEndOfInput() { LOGGER.debug("Closing this process' stdin at end of input."); try {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 3.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go
clientv3.OpGet(key), ).Commit() metrics.RecordEtcdRequest("delete", s.groupResourceString, err, startTime) if err != nil { return err } if !txnResp.Succeeded { getResp := (*clientv3.GetResponse)(txnResp.Responses[0].GetResponseRange()) klog.V(4).Infof("deletion of %s failed because of a conflict, going to retry", key) origState, err = s.getState(ctx, getResp, key, v, false) if err != nil { return err
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 35.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go
return &etcdClientKVWrapper{ KV: kv, getCallCounter: 0, } } func (ecw *etcdClientKVWrapper) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error) { resp, err := ecw.KV.Get(ctx, key, opts...) ecw.getCallCounter++ if err != nil { return nil, err } if len(ecw.getReactors) > 0 { reactor := ecw.getReactors[0]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 12.3K bytes - Viewed (0) -
platforms/core-runtime/daemon-protocol/src/main/java/org/gradle/launcher/daemon/protocol/DaemonMessageSerializer.java
private static class UserResponseSerializer implements Serializer<UserResponse> { @Override public void write(Encoder encoder, UserResponse message) throws Exception { encoder.writeString(message.getResponse()); } @Override public UserResponse read(Decoder decoder) throws Exception { return new UserResponse(decoder.readString()); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 18.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go
} type clientRecorder struct { reads uint64 clientv3.KV } func (r *clientRecorder) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error) { atomic.AddUint64(&r.reads, 1) return r.KV.Get(ctx, key, opts...) } func (r *clientRecorder) GetReadsAndReset() uint64 { return atomic.SwapUint64(&r.reads, 0) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 26.5K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbFile.java
cur.chain(closeReq); Smb2CreateResponse createResp = th.send(cr); Smb2CloseResponse closeResp = closeReq.getResponse(); SmbBasicFileInfo info; if ( ( closeResp.getCloseFlags() & Smb2CloseResponse.SMB2_CLOSE_FLAG_POSTQUERY_ATTIB ) != 0 ) { info = closeResp; }
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Thu May 23 01:50:13 UTC 2024 - 82.3K bytes - Viewed (1)