Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 194 for Sequence (0.05 seconds)

  1. build-logic/kotlin-dsl-shared-runtime/src/main/kotlin/org/gradle/kotlin/dsl/internal/sharedruntime/codegen/ApiExtensionGeneratorFacade.kt

            isKotlinCollection && typeArguments.single().isJavaClass
    
    
    private
    fun candidatesForExtensionFrom(type: ApiType): Sequence<ApiFunction> =
        type.functions.filter(::isCandidateForExtension).asSequence()
    
    
    private
    fun Sequence<ApiFunction>.sortedWithTypeOfTakingFunctionsFirst() =
        sortedBy { f ->
            if (f.parameters.any { it.type.isGradleTypeOf }) 0
            else 1
        }
    
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Wed Mar 12 15:56:18 GMT 2025
    - 17.8K bytes
    - Click Count (0)
  2. okhttp-tls/src/test/java/okhttp3/tls/internal/der/DerTest.kt

        }
      }
    
      /**
       * ```
       * Point ::= SEQUENCE {
       *   x [0] INTEGER OPTIONAL,
       *   y [1] INTEGER OPTIONAL
       * }
       * ```
       */
      data class Point(
        val x: Long?,
        val y: Long?,
      ) {
        companion object {
          val ADAPTER =
            Adapters.sequence(
              "Point",
              Adapters.INTEGER_AS_LONG.withTag(tag = 0L).optional(),
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 31.7K bytes
    - Click Count (0)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/EventRecorder.kt

          throw AssertionError("full event sequence: $fullEventSequence", e)
        }
      }
    
      inline fun <reified T : CallEvent> removeUpToEvent(): T = removeUpToEvent(T::class.java)
    
      inline fun <reified T : CallEvent> findEvent(): T = eventSequence.first { it is T } as T
    
      /**
       * Remove and return the next event from the recorded sequence.
       *
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Nov 05 18:28:35 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  4. internal/grid/muxserver.go

    				m.close()
    				return
    			}
    		}
    	}
    }
    
    // checkSeq will check if sequence number is correct and increment it by 1.
    func (m *muxServer) checkSeq(seq uint32) (ok bool) {
    	if seq != m.RecvSeq {
    		if debugPrint {
    			fmt.Printf("expected sequence %d, got %d\n", m.RecvSeq, seq)
    		}
    		m.disconnect(fmt.Sprintf("receive sequence number mismatch. want %d, got %d", m.RecvSeq, seq), false)
    		return false
    	}
    	m.RecvSeq++
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 9.7K bytes
    - Click Count (0)
  5. guava/src/com/google/common/collect/AbstractIndexedListIterator.java

      /** Returns the element with the specified index. This method is called by {@link #next()}. */
      @ParametricNullness
      protected abstract E get(int index);
    
      /**
       * Constructs an iterator across a sequence of the given size whose initial position is 0. That
       * is, the first call to {@link #next()} will return the first element (or throw {@link
       * NoSuchElementException} if {@code size} is zero).
       *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 3.2K bytes
    - Click Count (0)
  6. fastapi/_compat/v2.py

        return known_models
    
    
    def get_flat_models_from_fields(
        fields: Sequence[ModelField], known_models: TypeModelSet
    ) -> TypeModelSet:
        for field in fields:
            get_flat_models_from_field(field, known_models=known_models)
        return known_models
    
    
    def _regenerate_error_with_loc(
        *, errors: Sequence[Any], loc_prefix: tuple[Union[str, int], ...]
    ) -> list[dict[str, Any]]:
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Dec 27 12:54:56 GMT 2025
    - 19.1K bytes
    - Click Count (0)
  7. fastapi/_compat/shared.py

    import sys
    import types
    import typing
    import warnings
    from collections import deque
    from collections.abc import Mapping, Sequence
    from dataclasses import is_dataclass
    from typing import (
        Annotated,
        Any,
        Union,
    )
    
    from fastapi.types import UnionType
    from pydantic import BaseModel
    from pydantic.version import VERSION as PYDANTIC_VERSION
    from starlette.datastructures import UploadFile
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Dec 27 12:54:56 GMT 2025
    - 6.7K bytes
    - Click Count (0)
  8. fastapi/openapi/utils.py

    def get_openapi(
        *,
        title: str,
        version: str,
        openapi_version: str = "3.1.0",
        summary: Optional[str] = None,
        description: Optional[str] = None,
        routes: Sequence[BaseRoute],
        webhooks: Optional[Sequence[BaseRoute]] = None,
        tags: Optional[list[dict[str, Any]]] = None,
        servers: Optional[list[dict[str, Union[str, Any]]]] = None,
        terms_of_service: Optional[str] = None,
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Dec 27 12:54:56 GMT 2025
    - 23.2K bytes
    - Click Count (0)
  9. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt

              return eventClass.cast(event)
            }
          }
        } catch (e: NoSuchElementException) {
          throw AssertionError("full event sequence: $fullEventSequence", e)
        }
      }
    
      /**
       * Remove and return the next event from the recorded sequence.
       *
       * @param eventClass a class to assert that the returned event is an instance of, or null to
       *     take any event class.
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri May 30 21:28:20 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  10. cmd/global-heal.go

    	"github.com/minio/pkg/v3/console"
    	"github.com/minio/pkg/v3/wildcard"
    	"github.com/minio/pkg/v3/workers"
    )
    
    const (
    	bgHealingUUID = "0000-0000-0000-0000"
    )
    
    // NewBgHealSequence creates a background healing sequence
    // operation which scans all objects and heal them.
    func newBgHealSequence() *healSequence {
    	reqInfo := &logger.ReqInfo{API: "BackgroundHeal"}
    	ctx, cancelCtx := context.WithCancel(logger.SetReqInfo(GlobalContext, reqInfo))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Apr 04 13:49:12 GMT 2025
    - 16.2K bytes
    - Click Count (0)
Back to Top