Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 6 of 6 for onClose (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. guava/src/com/google/common/collect/Streams.java

                      return true;
                    }
                    return false;
                  }
                },
                isParallel)
            .onClose(streamA::close)
            .onClose(streamB::close);
      }
    
      /**
       * Invokes {@code consumer} once for each pair of <i>corresponding</i> elements in {@code streamA}
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 36.4K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/collect/Streams.java

                      return true;
                    }
                    return false;
                  }
                },
                isParallel)
            .onClose(streamA::close)
            .onClose(streamB::close);
      }
    
      /**
       * Invokes {@code consumer} once for each pair of <i>corresponding</i> elements in {@code streamA}
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 36.8K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/io/CharSource.java

      @IgnoreJRERequirement
      public Stream<String> lines() throws IOException {
        BufferedReader reader = openBufferedStream();
        return reader.lines().onClose(() -> closeUnchecked(reader));
      }
    
      @IgnoreJRERequirement // helper for lines()
      /*
       * If we make these calls inline inside the lambda inside lines(), we get an Animal Sniffer error,
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 25.7K bytes
    - Click Count (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/KotlinSourceModernTest.kt

            ) = TODO()
    
            override fun onClosing(
              webSocket: WebSocket,
              code: Int,
              reason: String,
            ) = TODO()
    
            override fun onClosed(
              webSocket: WebSocket,
              code: Int,
              reason: String,
            ) = TODO()
    
            override fun onFailure(
              webSocket: WebSocket,
              t: Throwable,
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Mar 10 21:47:20 GMT 2026
    - 49.7K bytes
    - Click Count (0)
  5. okhttp/api/jvm/okhttp.api

    	public abstract fun newWebSocket (Lokhttp3/Request;Lokhttp3/WebSocketListener;)Lokhttp3/WebSocket;
    }
    
    public abstract class okhttp3/WebSocketListener {
    	public fun <init> ()V
    	public fun onClosed (Lokhttp3/WebSocket;ILjava/lang/String;)V
    	public fun onClosing (Lokhttp3/WebSocket;ILjava/lang/String;)V
    	public fun onFailure (Lokhttp3/WebSocket;Ljava/lang/Throwable;Lokhttp3/Response;)V
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Mar 10 21:47:20 GMT 2026
    - 72.3K bytes
    - Click Count (0)
  6. okhttp/api/android/okhttp.api

    	public abstract fun newWebSocket (Lokhttp3/Request;Lokhttp3/WebSocketListener;)Lokhttp3/WebSocket;
    }
    
    public abstract class okhttp3/WebSocketListener {
    	public fun <init> ()V
    	public fun onClosed (Lokhttp3/WebSocket;ILjava/lang/String;)V
    	public fun onClosing (Lokhttp3/WebSocket;ILjava/lang/String;)V
    	public fun onFailure (Lokhttp3/WebSocket;Ljava/lang/Throwable;Lokhttp3/Response;)V
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Mar 10 21:47:20 GMT 2026
    - 72.3K bytes
    - Click Count (0)
Back to Top