SF-300

import akka.util.ByteString
import akka.stream._
import FanInShape.Name
import FanInShape.Init


class BinaryComparatorPorts(n: Int, _init: Init[Boolean] = Name("BinaryComparator")) extends UniformFanInShape[ByteString, Boolean](n, _init) {
  // comparison target; other ports are used for possible duplicates
  val src = newInlet[ByteString]("src")
  protected override def construct(init: Init[Boolean]) = new BinaryComparatorPorts(n, init)

SF-300

import unittest.mock

from fastapi import FastAPI as _FastAPI, APIRouter as _APIRouter, routing

__all__ = "FastAPI", "APIRouter" 


class APIRouter(_APIRouter):
    def include_router(self, router, **kwargs) -> None:
        prefix = kwargs.get("prefix", "")

SF-300

import asyncio
import contextlib
import inspect
from inspect import Parameter, Signature
from dataclasses import dataclass
from contextlib import AsyncExitStack, AbstractContextManager, AbstractAsyncContextManager
from typing import Callable, ParamSpec, TypeVar


__all__ = "Depends", "inject_and_run"

SF-300

from typing import TypeAlias, Type

from frozendict import frozendict
import sqlalchemy as sa
import sqlalchemy.types
import sqlalchemy.event
import sqlalchemy.schema
import sqlalchemy.sql.sqltypes

__all__ = "define_composite", "CreateComposite", "DropComposite"

SF-300

import operator as op

import sqlalchemy as sa

__all__ = "anyof_constraint",


def anyof_constraint(*cols, at_least_one: bool = False) -> sa.CheckConstraint:
    if len(cols) < 2:
        raise ValueError("At least 2 columns MUST be provided to create any-of constraint!")

SF-300

import weakref
import inspect

from typing import Callable, TypeVar, Protocol

__all__ = "Listenable", "Signal",

_Slot = TypeVar("_Slot", bound=Callable, contravariant=True)

SF-300

from types import SimpleNamespace
from typing import Any

__all__ = "NamespaceMeta", "Namespace"


class NamespaceMeta(type):
    """Provides namespacing infrastructure.
    This metaclass provides an alternative (and hopefully more convenient) syntax for creating 'types.SimpleNamespace'
    instances using 'class' syntax.

SF-300

from ctypes import windll, Structure, c_char, c_ushort, c_char_p, POINTER, c_int, WinError
from ctypes.wintypes import WORD

from typing import Literal, TypeAlias

__all__ = "test",

_ExtraInfo: TypeAlias = Literal["peername", "socket", "sockname"]

SF-300

# NOTE(zeronineseven): Heavily based on https://gist.github.com/denBot/4136279812f87819f86d99eba77c1ee0
import asyncio
import contextlib
import json
from contextlib import AsyncExitStack
from pathlib import Path
from typing import AsyncContextManager, Protocol, AsyncIterator, Never

import win32event
import win32pipe

SF-300

"""
This module provides a declarative way to describe delay strategies for controlling the interval between repeated actions, such as retrying a network request.

There are two categories of strategies:

1. Root Strategies: These provide the base logic for calculating delay time.
   - Linear: Increases delay time linearly.
   - Exponential: Increases delay time exponentially.

2. Modifier Strategies: These adjust the delay time calculated by a root strategy.