Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 272 for eventbus (0.1 sec)

  1. build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild.cache-miss-monitor.gradle.kts

     */
    
    @file:Suppress("UNCHECKED_CAST")
    
    import gradlebuild.AbstractBuildScanInfoCollectingService
    import gradlebuild.registerBuildScanInfoCollectingService
    import org.gradle.tooling.events.task.TaskOperationResult
    import org.gradle.tooling.events.task.TaskSuccessResult
    import java.io.Serializable
    import java.util.concurrent.atomic.AtomicBoolean
    
    /**
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Thu Mar 07 05:49:29 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  2. tests/test_sub_callbacks.py

        pass  # pragma: nocover
    
    
    class Event(BaseModel):
        name: str
        total: float
    
    
    events_callback_router = APIRouter()
    
    
    @events_callback_router.get("{$callback_url}/events/{$request.body.title}")
    def event_callback(event: Event):
        pass  # pragma: nocover
    
    
    subrouter = APIRouter()
    
    
    @subrouter.post("/invoices/", callbacks=invoices_callback_router.routes)
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri Jul 07 17:12:13 UTC 2023
    - 13.8K bytes
    - Viewed (0)
  3. tests/test_tutorial/test_events/test_tutorial002.py

    import pytest
    from fastapi import FastAPI
    from fastapi.testclient import TestClient
    
    
    @pytest.fixture(name="app", scope="module")
    def get_app():
        with pytest.warns(DeprecationWarning):
            from docs_src.events.tutorial002 import app
        yield app
    
    
    def test_events(app: FastAPI):
        with TestClient(app) as client:
            response = client.get("/items/")
            assert response.status_code == 200, response.text
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Oct 18 12:36:40 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  4. samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt

    import okio.ByteString.Companion.toByteString
    
    /**
     * Logs SSL keys to a log file, allowing Wireshark to decode traffic and be examined with http2
     * filter. The approach is to hook into JSSE log events for the messages between client and server
     * during handshake, and then take the agreed masterSecret from private fields of the session.
     *
     * Copy WireSharkKeyLoggerListener to your test code to use in development.
     *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  5. .github/workflows/multipart/nginx-site1.conf

    user  nginx;
    worker_processes  auto;
    
    error_log  /var/log/nginx/error.log warn;
    pid        /var/run/nginx.pid;
    
    events {
        worker_connections  4096;
    }
    
    http {
        include       /etc/nginx/mime.types;
        default_type  application/octet-stream;
    
        log_format  main  '$remote_addr - $remote_user [$time_local] "$request" '
                          '$status $body_bytes_sent "$http_referer" '
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 30 10:13:56 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  6. .github/workflows/multipart/nginx-site2.conf

    user  nginx;
    worker_processes  auto;
    
    error_log  /var/log/nginx/error.log warn;
    pid        /var/run/nginx.pid;
    
    events {
        worker_connections  4096;
    }
    
    http {
        include       /etc/nginx/mime.types;
        default_type  application/octet-stream;
    
        log_format  main  '$remote_addr - $remote_user [$time_local] "$request" '
                          '$status $body_bytes_sent "$http_referer" '
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 30 10:13:56 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  7. docs/extensions/s3zip/examples/boto3/main.py

            config=Config(signature_version='s3v4'),
            region_name='us-east-1')
    
    
    def _add_header(request, **kwargs):
        request.headers.add_header('x-minio-extract', 'true')
    event_system = s3.meta.events
    event_system.register_first('before-sign.s3.*', _add_header)
    
    # List zip contents
    response = s3.list_objects_v2(Bucket="your-bucket", Prefix="path/to/file.zip/")
    print(response)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 04 21:15:45 UTC 2021
    - 771 bytes
    - Viewed (0)
  8. tests/test_tutorial/test_events/test_tutorial001.py

    import pytest
    from fastapi import FastAPI
    from fastapi.testclient import TestClient
    
    
    @pytest.fixture(name="app", scope="module")
    def get_app():
        with pytest.warns(DeprecationWarning):
            from docs_src.events.tutorial001 import app
        yield app
    
    
    def test_events(app: FastAPI):
        with TestClient(app) as client:
            response = client.get("/items/foo")
            assert response.status_code == 200, response.text
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Wed Oct 18 12:36:40 UTC 2023
    - 3.6K bytes
    - Viewed (0)
  9. buildscripts/upgrade-tests/nginx.conf

    user  nginx;
    worker_processes  auto;
    
    error_log  /var/log/nginx/error.log warn;
    pid        /var/run/nginx.pid;
    
    
    events {
        worker_connections  1024;
    }
    
    
    http {
        include       /etc/nginx/mime.types;
        default_type  application/octet-stream;
    
        log_format  main  '$remote_addr - $remote_user [$time_local] "$request" '
                          '$status $body_bytes_sent "$http_referer" '
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Nov 21 18:41:30 UTC 2021
    - 1.7K bytes
    - Viewed (0)
  10. tests/test_tutorial/test_events/test_tutorial003.py

    from fastapi.testclient import TestClient
    
    from docs_src.events.tutorial003 import (
        app,
        fake_answer_to_everything_ml_model,
        ml_models,
    )
    
    
    def test_events():
        assert not ml_models, "ml_models should be empty"
        with TestClient(app) as client:
            assert ml_models["answer_to_everything"] == fake_answer_to_everything_ml_model
            response = client.get("/predict", params={"x": 2})
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri Jun 30 18:25:16 UTC 2023
    - 3.6K bytes
    - Viewed (0)
Back to top