- Sort Score
- Result 10 results
- Languages All
Results 1041 - 1050 of 6,918 for RETURN (0.04 sec)
-
internal/s3select/message.go
func (writer *messageWriter) SendRecord(payload *bytes.Buffer) error { select { case writer.payloadCh <- payload: return nil case <-writer.doneCh: return fmt.Errorf("messageWriter is done") } } func (writer *messageWriter) flushRecords() bool { if writer.payloadBufferIndex == 0 { return true } result := writer.write(newRecordsMessage(writer.payloadBuffer[0:writer.payloadBufferIndex])) if result {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 30 15:26:43 UTC 2022 - 15.2K bytes - Viewed (0) -
compat/maven-settings-builder/src/main/java/org/apache/maven/settings/building/DefaultSettingsBuildingRequest.java
@Override public File getGlobalSettingsFile() { return globalSettingsFile; } @Override public DefaultSettingsBuildingRequest setGlobalSettingsFile(File globalSettingsFile) { this.globalSettingsFile = globalSettingsFile; return this; } @Override public SettingsSource getGlobalSettingsSource() { return globalSettingsSource; } @Override
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 4.5K bytes - Viewed (0) -
samples/slack/src/main/java/okhttp3/slack/SlackApi.java
JsonAdapter<RtmStartResponse> jsonAdapter = moshi.adapter(RtmStartResponse.class); return jsonAdapter.fromJson(response.body().source()); } } /** See https://api.slack.com/rtm. */ public WebSocket rtm(HttpUrl url, WebSocketListener listener) { return httpClient.newWebSocket(new Request.Builder() .url(url) .build(), listener); }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Fri Jul 06 19:30:55 UTC 2018 - 4.4K bytes - Viewed (0) -
istioctl/pkg/tag/revision.go
} } } return revisions, nil } func Webhooks(ctx context.Context, client kube.CLIClient) ([]admitv1.MutatingWebhookConfiguration, error) { hooks, err := client.Kube().AdmissionregistrationV1().MutatingWebhookConfigurations().List(ctx, metav1.ListOptions{}) if err != nil { return []admitv1.MutatingWebhookConfiguration{}, err } return hooks.Items, nil }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 4.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ForwardingBlockingQueue.java
return delegate().drainTo(c, maxElements); } @CanIgnoreReturnValue @Override public int drainTo(Collection<? super E> c) { return delegate().drainTo(c); } @CanIgnoreReturnValue // TODO(kak): consider removing this @Override public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException { return delegate().offer(e, timeout, unit); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 3K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/ArtifactFactory.java
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Tue Aug 27 21:13:34 UTC 2024 - 3.3K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/DependencyCoordinatesFactory.java
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Tue Aug 27 21:13:34 UTC 2024 - 3.4K bytes - Viewed (0) -
docs/sts/client_grants/__init__.py
""" if self.cid is not None: fetcher = self._create_credentials_fetcher() return RefreshableCredentials.create_from_metadata( metadata=fetcher(), refresh_using=fetcher, method=self.METHOD, ) else: return None def _create_credentials_fetcher(self): method = self.METHOD def fetch_credentials():
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Apr 23 18:58:53 UTC 2021 - 4.6K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/MinimalSet.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:05:46 UTC 2024 - 2.8K bytes - Viewed (0) -
fastapi/applications.py
response.headers["X-Process-Time"] = str(process_time) return response ``` """ def decorator(func: DecoratedCallable) -> DecoratedCallable: self.add_middleware(BaseHTTPMiddleware, dispatch=func) return func return decorator def exception_handler( self,
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sat Aug 17 04:52:31 UTC 2024 - 172.2K bytes - Viewed (0)