Search Options

Results per page
Sort
Preferred Languages
Advance

Results 241 - 250 of 702 for sont (0.1 sec)

  1. internal/event/target/mqtt.go

    	if err != nil {
    		return err
    	}
    
    	eventData, err := target.store.Get(key)
    	if err != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(err) {
    			return nil
    		}
    		return err
    	}
    
    	if err = target.send(eventData); err != nil {
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  2. guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ImmutableList.java

          Iterable<? extends E> elements) {
        Comparable<?>[] array = Iterables.toArray(elements, new Comparable<?>[0]);
        checkElementsNotNull((Object[]) array);
        Arrays.sort(array);
        return asImmutableList(array);
      }
    
      public static <E> ImmutableList<E> sortedCopyOf(
          Comparator<? super E> comparator, Iterable<? extends E> elements) {
        checkNotNull(comparator);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 14 22:14:46 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt

        internal set
    
      /** Received headers yet to be [taken][takeHeaders]. */
      private val headersQueue = ArrayDeque<Headers>()
    
      /** True if response headers have been sent or received. */
      private var hasResponseHeaders: Boolean = false
    
      internal val source =
        FramingSource(
          maxByteCount = connection.okHttpSettings.initialWindowSize.toLong(),
          finished = inFinished,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  4. src/main/webapp/js/suggestor.js

                //style sheet
                $boxElement.css("display", "none");
                $boxElement.css("position", "absolute");
                $boxElement.css("text-align", "left");
                $boxElement.css("font-size", $element.css("font-size"));
                if (typeof setting.boxCssInfo === "undefined") {
                  $boxElement.css("border", "1px solid #cccccc");
                  $boxElement.css(
                    "-webkit-box-shadow",
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Mar 30 05:45:24 UTC 2023
    - 13.3K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt

          // Masked payloads must be read on the server. Unmasked payloads must be read on the client.
          throw ProtocolException(
            if (isClient) {
              "Server-sent frames must not be masked."
            } else {
              "Client-sent frames must be masked."
            },
          )
        }
    
        // Get frame length, optionally reading from follow-up bytes if indicated by special values.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9.8K bytes
    - Viewed (0)
  6. src/main/webapp/WEB-INF/orig/view/login/index.jsp

    <meta http-equiv="X-UA-Compatible" content="IE=edge">
    <title><la:message key="labels.login.title" /></title>
    <link href="${fe:url('/css/admin/bootstrap.min.css')}" rel="stylesheet" type="text/css" />
    <link href="${fe:url('/css/admin/font-awesome.min.css')}" rel="stylesheet" type="text/css" />
    <link href="${fe:url('/css/admin/adminlte.min.css')}" rel="stylesheet" type="text/css" />
    <link href="${fe:url('/css/admin/style.css')}" rel="stylesheet" type="text/css" />
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 26 01:07:52 UTC 2024
    - 3K bytes
    - Viewed (0)
  7. tests/test_tutorial/test_schema_extra_example/test_tutorial004_an_py310.py

    @pytest.fixture(name="client")
    def get_client():
        from docs_src.schema_extra_example.tutorial004_an_py310 import app
    
        client = TestClient(app)
        return client
    
    
    # Test required and embedded body parameters with no bodies sent
    @needs_py310
    def test_post_body_example(client: TestClient):
        response = client.put(
            "/items/5",
            json={
                "name": "Foo",
                "description": "A very nice Item",
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri Jul 07 17:12:13 UTC 2023
    - 7.1K bytes
    - Viewed (0)
  8. istioctl/pkg/writer/envoy/configdump/cluster.go

    // See the License for the specific language governing permissions and
    // limitations under the License.
    
    package configdump
    
    import (
    	"encoding/json"
    	"fmt"
    	"sort"
    	"strings"
    	"text/tabwriter"
    
    	cluster "github.com/envoyproxy/go-control-plane/envoy/config/cluster/v3"
    	"sigs.k8s.io/yaml"
    
    	"istio.io/istio/istioctl/pkg/util/proto"
    	"istio.io/istio/pilot/pkg/model"
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu May 11 05:38:17 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  9. api/maven-api-core/src/main/java/org/apache/maven/api/Event.java

     * under the License.
     */
    package org.apache.maven.api;
    
    import java.util.Optional;
    
    import org.apache.maven.api.annotations.Experimental;
    import org.apache.maven.api.annotations.Nonnull;
    
    /**
     * Event sent by maven during various phases of the build process.
     * Such events can be listened to using {@link Listener}s objects
     * registered in the {@link Session}.
     *
     * @since 4.0.0
     */
    @Experimental
    public interface Event {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Thu Mar 23 05:29:39 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  10. cmd/bucket-lifecycle-handlers_test.go

    	credentials auth.Credentials, t *testing.T,
    ) {
    	// test cases with sample input and expected output.
    	testCases := []struct {
    		method     string
    		bucketName string
    		accessKey  string
    		secretKey  string
    		// Sent body
    		body []byte
    		// Expected response
    		expectedRespStatus int
    		lifecycleResponse  []byte
    		errorResponse      APIErrorResponse
    		shouldPass         bool
    	}{
    		// GET empty credentials
    		{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 11.3K bytes
    - Viewed (0)
Back to top