Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 1,027 for Closer (0.24 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketReader.kt

        while (true) {
          if (closed) throw IOException("closed")
    
          if (frameLength > 0L) {
            source.readFully(messageFrameBuffer, frameLength)
    
            if (!isClient) {
              messageFrameBuffer.readAndWriteUnsafe(maskCursor!!)
              maskCursor.seek(messageFrameBuffer.size - frameLength)
              toggleMask(maskCursor, maskKey!!)
              maskCursor.close()
            }
          }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jul 29 22:04:11 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  2. mockwebserver-junit5/src/test/java/mockwebserver3/junit5/StartStopTest.kt

              assertThat(dispatcherE.closed).isTrue()
              assertThat(dispatcherF.closed).isFalse() // Never started.
            }
          }
      }
    
      class ClosableDispatcher : Dispatcher() {
        var closed = false
    
        override fun dispatch(request: RecordedRequest) = MockResponse()
    
        override fun close() {
          closed = true
        }
      }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 11:13:17 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  3. src/test/java/jcifs/util/ResourceManagerTest.java

            private final AtomicBoolean closed = new AtomicBoolean(false);
            private final String name;
    
            TestResource(String name) {
                this.name = name;
            }
    
            @Override
            public void close() {
                closed.set(true);
            }
    
            boolean isClosed() {
                return closed.get();
            }
    
            String getName() {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/Exchange.kt

            throw complete(e)!!
          }
        }
    
        @Throws(IOException::class)
        override fun close() {
          if (closed) return
          closed = true
          if (contentLength != -1L && bytesReceived != contentLength) {
            throw ProtocolException("unexpected end of stream")
          }
          try {
            super.close()
            complete(null)
          } catch (e: IOException) {
            throw complete(e)!!
          }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jul 29 22:04:11 UTC 2025
    - 9.7K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/core/io/CloseableUtilTest.java

            CloseableUtil.close(out);
        }
    
        private static class NotifyOutputStream extends OutputStream {
            private String notify_;
    
            @Override
            public void write(final int arg0) throws IOException {
            }
    
            @Override
            public void close() throws IOException {
                super.close();
                notify_ = "closed";
            }
    
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Sat May 10 01:32:17 UTC 2025
    - 2.2K bytes
    - Viewed (0)
  6. src/test/java/jcifs/smb/SmbPipeHandleImplTest.java

        }
    
        @Test
        @DisplayName("ensureOpen throws after close() is called")
        void testEnsureOpenAfterClose() throws CIFSException {
            target.close();
            CIFSException ex = assertThrows(SmbException.class, () -> target.ensureOpen());
            assertTrue(ex.getMessage().contains("Pipe handle already closed"));
        }
    
        @Test
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  7. src/archive/zip/writer_test.go

    			}
    			continue
    		} else {
    			if !test.ok {
    				t.Fatalf("SetComment: unexpected success, want error")
    			}
    		}
    
    		if err := w.Close(); test.ok == (err != nil) {
    			t.Fatal(err)
    		}
    
    		if w.closed != test.ok {
    			t.Fatalf("Writer.closed: got %v, want %v", w.closed, test.ok)
    		}
    
    		// skip read test in failure cases
    		if !test.ok {
    			continue
    		}
    
    		// read it back
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Jan 28 04:20:09 UTC 2025
    - 14.4K bytes
    - Viewed (0)
  8. .github/stale.yml

    # Number of days of inactivity before an Issue or Pull Request becomes stale
    daysUntilStale: 30
    
    # Number of days of inactivity before an Issue or Pull Request with the stale label is closed.
    # Set to false to disable. If disabled, issues still need to be closed manually, but will remain marked as stale.
    daysUntilClose: 15
    
    # Only issues or pull requests with all of these labels are check if stale. Defaults to `[]` (disabled)
    onlyLabels: []
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Jan 24 04:36:59 UTC 2022
    - 2K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Writer.kt

      }
    
      @Throws(IOException::class)
      fun flush() {
        withLock {
          if (closed) throw IOException("closed")
          sink.flush()
        }
      }
    
      @Throws(IOException::class)
      fun rstStream(
        streamId: Int,
        errorCode: ErrorCode,
      ) {
        withLock {
          if (closed) throw IOException("closed")
          require(errorCode.httpCode != -1)
    
          frameHeader(
            streamId = streamId,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 11K bytes
    - Viewed (0)
  10. .github/workflows/stale.yml

    permissions:
      contents: read
    
    jobs:
      stale:
        permissions:
          issues: write  # for actions/stale to close stale issues
          pull-requests: write  # for actions/stale to close stale PRs
        runs-on: ubuntu-latest
        env:
          ACTIONS_STEP_DEBUG: true
        steps:
        - name: Close Stale Issues
          uses: actions/stale@v8
          with:
            repo-token: ${{ secrets.GITHUB_TOKEN }}
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Tue Apr 11 02:27:05 UTC 2023
    - 972 bytes
    - Viewed (0)
Back to top