Search Options

Results per page
Sort
Preferred Languages
Advance

Results 281 - 290 of 757 for closely (0.04 sec)

  1. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketRecorder.kt

        val delegate = delegate
        if (delegate != null) {
          this.delegate = null
          delegate.onClosed(webSocket, code, reason)
        } else {
          events.add(Closed(code, reason))
        }
      }
    
      override fun onFailure(
        webSocket: WebSocket,
        t: Throwable,
        response: Response?,
      ) {
        Platform.get().log("[WS $name] onFailure", Platform.INFO, t)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 6.8K bytes
    - Viewed (0)
  2. cmd/event-notification.go

    func (evnot *EventNotifier) RemoveNotification(bucketName string) {
    	evnot.Lock()
    	defer evnot.Unlock()
    
    	delete(evnot.bucketRulesMap, bucketName)
    }
    
    // RemoveAllBucketTargets - closes and removes all notification targets.
    func (evnot *EventNotifier) RemoveAllBucketTargets() {
    	evnot.Lock()
    	defer evnot.Unlock()
    
    	targetIDSet := event.NewTargetIDSet()
    	for k := range evnot.targetList.TargetMap() {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  3. src/test/java/jcifs/smb1/dcerpc/msrpc/LsaPolicyHandleTest.java

            doThrow(new IOException("Close network error")).when(mockDcerpcHandle).sendrecv(any(MsrpcLsarClose.class));
    
            // Act & Assert
            IOException thrown = assertThrows(IOException.class, () -> {
                handle.close();
            });
    
            assertEquals("Close network error", thrown.getMessage());
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  4. okhttp-sse/src/main/kotlin/okhttp3/sse/EventSourceListener.kt

        type: String?,
        data: String,
      ) {
      }
    
      /**
       * Invoked when the HTTP connection has been closed normally.
       *
       * No further calls to this listener will be made.
       */
      open fun onClosed(eventSource: EventSource) {
      }
    
      /**
       * Invoked when an event source has been closed due to an error reading from or writing to the
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:47:47 UTC 2025
    - 1.7K bytes
    - Viewed (0)
  5. okhttp-logging-interceptor/src/test/java/okhttp3/logging/HttpLoggingInterceptorTest.kt

          MockResponse
            .Builder()
            .body("Hello!")
            .setHeader("Content-Type", PLAIN)
            .build(),
        )
        val response = client.newCall(request().build()).execute()
        response.body.close()
        applicationLogs
          .assertLogEqual("--> GET $url")
          .assertLogMatch(Regex("""<-- 200 OK $url \(\d+ms, 6-byte body\)"""))
          .assertNoMoreLogs()
        networkLogs
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Aug 21 14:27:04 UTC 2025
    - 37.5K bytes
    - Viewed (0)
  6. src/main/webapp/WEB-INF/view/admin/suggest/admin_suggest.jsp

                                                                            <button type="button" class="close"
                                                                                    data-dismiss="modal"
                                                                                    aria-label="Close">
                                                                                <span aria-hidden="true">×</span>
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Wed Feb 12 20:25:27 UTC 2020
    - 18.1K bytes
    - Viewed (0)
  7. src/main/java/jcifs/SmbTransportPool.java

         */
        void removeTransport(SmbTransport trans);
    
        /**
         * Closes the pool and all connections in it
         *
         * @return whether any transport was still in use
         *
         * @throws CIFSException if an error occurs during authentication
         *
         */
        boolean close() throws CIFSException;
    
        /**
         * Authenticate arbitrary credentials represented by the
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  8. src/main/java/jcifs/dcerpc/msrpc/MsrpcSamrCloseHandle.java

    import jcifs.dcerpc.rpc.policy_handle;
    
    /**
     * Microsoft RPC SAM close handle request.
     * This class implements the SAMR close handle operation.
     *
     * @author mbechler
     */
    public class MsrpcSamrCloseHandle extends samr.SamrCloseHandle {
    
        /**
         * Creates a new request to close a SAM handle.
         *
         * @param handle the policy handle to close
         */
        public MsrpcSamrCloseHandle(final policy_handle handle) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 1.4K bytes
    - Viewed (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/MessageDeflaterInflaterTest.kt

      }
    
      @Test fun `deflate after close`() {
        val deflater = MessageDeflater(true)
        deflater.close()
    
        assertFailsWith<Exception> {
          deflater.deflate("Hello deflate!".encodeUtf8())
        }
      }
    
      @Test fun `inflate after close`() {
        val inflater = MessageInflater(false)
    
        inflater.close()
    
        assertFailsWith<Exception> {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 5K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb1/dcerpc/msrpc/MsrpcSamrCloseHandle.java

    import jcifs.smb1.dcerpc.rpc;
    
    /**
     * MS-RPC SAMR close handle operation.
     *
     * This class implements the SAMR CloseHandle operation for releasing
     * Security Account Manager (SAM) handles.
     */
    public class MsrpcSamrCloseHandle extends samr.SamrCloseHandle {
    
        /**
         * Creates a new request to close a SAM handle.
         *
         * @param policyHandle the policy handle to close
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 1.5K bytes
    - Viewed (0)
Back to top