Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 58 for Closeable (0.21 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

      final ExecutorService closingExecutor = newSingleThreadExecutor();
    
      final TestCloseable closeable1 = new TestCloseable("closeable1");
      final TestCloseable closeable2 = new TestCloseable("closeable2");
      final TestCloseable closeable3 = new TestCloseable("closeable3");
      final TestCloseable closeable4 = new TestCloseable("closeable4");
    
      final Waiter waiter = new Waiter();
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 74.7K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

      final ExecutorService closingExecutor = newSingleThreadExecutor();
    
      final TestCloseable closeable1 = new TestCloseable("closeable1");
      final TestCloseable closeable2 = new TestCloseable("closeable2");
      final TestCloseable closeable3 = new TestCloseable("closeable3");
      final TestCloseable closeable4 = new TestCloseable("closeable4");
    
      final Waiter waiter = new Waiter();
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 75.3K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/io/CloserTest.java

          this.closeable = closeable;
          this.thrown = thrown;
          this.suppressed = suppressed;
        }
    
        @Override
        public boolean equals(@Nullable Object obj) {
          if (obj instanceof Suppression) {
            Suppression other = (Suppression) obj;
            return closeable.equals(other.closeable)
                && thrown.equals(other.thrown)
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Mar 06 15:15:46 GMT 2024
    - 13.6K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/io/Closer.java

       * @return the given {@code closeable}
       */
      // close. this word no longer has any meaning to me.
      @CanIgnoreReturnValue
      @ParametricNullness
      public <C extends @Nullable Closeable> C register(@ParametricNullness C closeable) {
        if (closeable != null) {
          stack.addFirst(closeable);
        }
    
        return closeable;
      }
    
      /**
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Mar 06 15:15:46 GMT 2024
    - 11.9K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/io/CloserTest.java

          this.closeable = closeable;
          this.thrown = thrown;
          this.suppressed = suppressed;
        }
    
        @Override
        public boolean equals(@Nullable Object obj) {
          if (obj instanceof Suppression) {
            Suppression other = (Suppression) obj;
            return closeable.equals(other.closeable)
                && thrown.equals(other.thrown)
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Mar 06 15:15:46 GMT 2024
    - 13.6K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/core/io/CloseableUtil.java

         * {@link #close(Closeable)}でも 例外が発生する可能性があります。その場合に{@literal finally}
         * ブロックから例外をスローすると、 {@literal try}ブロックで発生した元の例外が失われてしまいます。
         * </p>
         *
         * @param closeable
         *            クローズ可能なオブジェクト
         * @see Closeable#close()
         */
        public static void close(final Closeable closeable) {
            if (closeable == null) {
                return;
            }
            try {
    Java
    - Registered: Fri May 03 20:58:11 GMT 2024
    - Last Modified: Thu Mar 07 01:59:08 GMT 2024
    - 2.5K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

        public <C extends @Nullable Object & @Nullable Closeable> C eventuallyClose(
            @ParametricNullness C closeable, Executor closingExecutor) {
          checkNotNull(closingExecutor);
          if (closeable != null) {
            list.add(closeable, closingExecutor);
          }
          return closeable;
        }
      }
    
      /**
       * An operation that computes a result.
       *
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 98.5K bytes
    - Viewed (0)
  8. okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpDebugLogging.kt

            }
        }
    
      fun enable(
        loggerClass: String,
        handler: Handler = logHandler(),
      ): Closeable {
        val logger = Logger.getLogger(loggerClass)
        if (configuredLoggers.add(logger)) {
          logger.addHandler(handler)
          logger.level = Level.FINEST
        }
        return Closeable {
          logger.removeHandler(handler)
        }
      }
    
      fun enable(loggerClass: KClass<*>) = enable(loggerClass.java.name)
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 1.9K bytes
    - Viewed (0)
  9. okhttp-testing-support/src/main/kotlin/okhttp3/JsseDebugLogging.kt

     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3
    
    import java.io.Closeable
    import java.util.logging.Handler
    import java.util.logging.LogRecord
    
    object JsseDebugLogging {
      data class JsseDebugMessage(val message: String, val param: String?) {
        enum class Type {
          Handshake,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/ws/MessageInflater.kt

     * limitations under the License.
     */
    package okhttp3.internal.ws
    
    import java.io.Closeable
    import java.io.IOException
    import java.util.zip.Inflater
    import okio.Buffer
    import okio.InflaterSource
    
    private const val OCTETS_TO_ADD_BEFORE_INFLATION = 0x0000ffff
    
    class MessageInflater(
      private val noContextTakeover: Boolean,
    ) : Closeable {
      private val deflatedBytes = Buffer()
    
      private val inflater =
        Inflater(
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 1.8K bytes
    - Viewed (0)
Back to top