Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1041 - 1050 of 6,918 for RETURN (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. api/maven-api-core/src/main/java/org/apache/maven/api/services/ArtifactFactory.java

                String extension,
                String type) {
            return create(ArtifactFactoryRequest.build(session, groupId, artifactId, version, classifier, extension, type));
        }
    
        /**
         * Creates an artifact.
         *
         * @param request the request holding artifact creation parameters
         * @return an {@code Artifact}, never {@code null}
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Tue Aug 27 21:13:34 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  7. api/maven-api-core/src/main/java/org/apache/maven/api/services/DependencyCoordinatesFactory.java

            return create(DependencyCoordinatesFactoryRequest.build(session, coordinates));
        }
    
        @Nonnull
        default DependencyCoordinates create(
                @Nonnull Session session, @Nonnull org.apache.maven.api.Dependency dependency) {
            return create(DependencyCoordinatesFactoryRequest.build(session, dependency));
        }
    
        @Nonnull
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Tue Aug 27 21:13:34 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  8. 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)
  9. android/guava-testlib/src/com/google/common/collect/testing/MinimalSet.java

        if (object instanceof Set) {
          Set<?> that = (Set<?>) object;
          return (this.size() == that.size()) && this.containsAll(that);
        }
        return false;
      }
    
      @Override
      public int hashCode() {
        int hashCodeSum = 0;
        for (Object o : this) {
          hashCodeSum += (o == null) ? 0 : o.hashCode();
        }
        return hashCodeSum;
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  10. 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)
Back to top