Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 336 for emit (0.12 sec)

  1. okhttp/src/test/java/okhttp3/SocksProxy.kt

          }
        }
        when (selectedMethod) {
          METHOD_NO_AUTHENTICATION_REQUIRED -> {
            fromSink.writeByte(VERSION_5)
            fromSink.writeByte(selectedMethod)
            fromSink.emit()
          }
          else -> throw ProtocolException("unsupported method: $selectedMethod")
        }
      }
    
      private fun acceptCommand(
        fromAddress: InetAddress,
        fromSource: BufferedSource,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 11 22:09:35 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketWriter.kt

      private val minimumDeflateSize: Long,
    ) : Closeable {
      /** This holds outbound data for compression and masking. */
      private val messageBuffer = Buffer()
    
      /** The [Buffer] of [sink]. Write to this and then flush/emit [sink]. */
      private val sinkBuffer: Buffer = sink.buffer
      private var writerClosed = false
    
      /** Lazily initialized on first use. */
      private var messageDeflater: MessageDeflater? = null
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 5.9K bytes
    - Viewed (0)
  3. analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirResolveExtensionInfoProvider.kt

            emptySequence()
        }
    
        override fun getPackageSymbols(nameFilter: KtScopeNameFilter): Sequence<KtPackageSymbol> = withValidityAssertion {
            sequence {
                // Only emit package symbols for top-level packages (subpackages of root). This matches the behavior
                // of the root-level KtFirPackageScope.
                val seenTopLevelPackages = mutableSetOf<Name>()
    Plain Text
    - Registered: Fri Apr 26 08:18:10 GMT 2024
    - Last Modified: Fri Apr 19 11:06:47 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  4. manifests/helm-profiles/warning-edit.txt

    # WARNING: DO NOT EDIT, THIS FILE IS A COPY.
    # The original version of this file is located at /manifests/helm-profiles directory.
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 02 22:30:06 GMT 2024
    - 218 bytes
    - Viewed (0)
  5. docs/de/docs/tutorial/middleware.md

    * Sie nimmt dann die **Response** entgegen, die von der Anwendung generiert wurde (durch eine bestimmte *Pfadoperation*).
    * Sie kann etwas mit dieser **Response** tun oder beliebigen Code ausführen.
    * Dann gibt sie die **Response** zurück.
    
    !!! note "Technische Details"
        Wenn Sie Abhängigkeiten mit `yield` haben, wird der Exit-Code *nach* der Middleware ausgeführt.
    
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Tue Jan 23 11:26:59 GMT 2024
    - 3.4K bytes
    - Viewed (0)
  6. apache-maven/src/main/appended-resources/licenses/MIT-slf4j-api-2.0.11.txt

    Guillaume Nodet <******@****.***> 1704782218 +0100
    Plain Text
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Tue Jan 09 06:36:58 GMT 2024
    - 1.1K bytes
    - Viewed (0)
  7. common/scripts/setup_env.sh

    #!/bin/bash
    # shellcheck disable=SC2034
    
    # WARNING: DO NOT EDIT, THIS FILE IS PROBABLY A COPY
    #
    # The original version of this file is located in the https://github.com/istio/common-files repo.
    # If you're looking at this file in a different repo and want to make a change, please go to the
    # common-files repo, make the change there and check it in. Then come back to this repo and run
    # "make update-common".
    
    # Copyright Istio Authors
    #
    Shell Script
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu May 02 16:31:40 GMT 2024
    - 7.6K bytes
    - Viewed (0)
  8. common-protos/k8s.io/api/admission/v1/generated.proto

    See the License for the specific language governing permissions and
    limitations under the License.
    */
    
    
    // This file was autogenerated by go-to-protobuf. Do not edit it manually!
    
    syntax = "proto2";
    
    package k8s.io.api.admission.v1;
    
    import "k8s.io/api/authentication/v1/generated.proto";
    import "k8s.io/apimachinery/pkg/apis/meta/v1/generated.proto";
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 8.1K bytes
    - Viewed (0)
  9. common-protos/k8s.io/api/admission/v1beta1/generated.proto

    See the License for the specific language governing permissions and
    limitations under the License.
    */
    
    
    // This file was autogenerated by go-to-protobuf. Do not edit it manually!
    
    syntax = "proto2";
    
    package k8s.io.api.admission.v1beta1;
    
    import "k8s.io/api/authentication/v1/generated.proto";
    import "k8s.io/apimachinery/pkg/apis/meta/v1/generated.proto";
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Mar 11 18:43:24 GMT 2024
    - 8.1K bytes
    - Viewed (0)
  10. fastapi/concurrency.py

        except Exception as e:
            ok = bool(
                await anyio.to_thread.run_sync(
                    cm.__exit__, type(e), e, None, limiter=exit_limiter
                )
            )
            if not ok:
                raise e
        else:
            await anyio.to_thread.run_sync(
                cm.__exit__, None, None, None, limiter=exit_limiter
    Python
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Mon Dec 25 17:57:35 GMT 2023
    - 1.4K bytes
    - Viewed (0)
Back to top