- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 193 for Beek (0.43 sec)
-
.teamcity/src/main/kotlin/model/CIBuildModel.kt
PerformanceTestCoverage(5, PerformanceTestType.per_week, Os.LINUX, numberOfBuckets = 20, oldUuid = "PerformanceTestExperimentLinux"), PerformanceTestCoverage(8, PerformanceTestType.per_week, Os.WINDOWS, numberOfBuckets = 5), PerformanceTestCoverage(9, PerformanceTestType.per_week, Os.MACOS, numberOfBuckets = 5) ) ), Stage(
Plain Text - Registered: Wed May 08 11:36:15 GMT 2024 - Last Modified: Fri Feb 23 01:54:48 GMT 2024 - 20.9K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt
override fun dispatch(request: mockwebserver3.RecordedRequest): mockwebserver3.MockResponse { return delegate.dispatch(request.unwrap()).wrap() } override fun peek(): mockwebserver3.MockResponse { return delegate.peek().wrap() } override fun shutdown() { delegate.shutdown() } } } internal fun MockResponse.wrap(): mockwebserver3.MockResponse {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java
assertEquals(3, (int) mmHeap.pollLast()); assertEquals(1, (int) mmHeap.peek()); assertEquals(2, (int) mmHeap.peekLast()); assertEquals(2, (int) mmHeap.pollLast()); assertEquals(1, (int) mmHeap.peek()); assertEquals(1, (int) mmHeap.peekLast()); assertEquals(1, (int) mmHeap.pollLast()); assertNull(mmHeap.peek()); assertNull(mmHeap.peekLast()); assertNull(mmHeap.pollLast()); }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Mar 07 18:34:03 GMT 2024 - 36.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java
public boolean remove(Object object) { assertTrue(Thread.holdsLock(mutex)); return delegate.remove(object); } @Override public @Nullable E peek() { assertTrue(Thread.holdsLock(mutex)); return delegate.peek(); } @Override public E element() { assertTrue(Thread.holdsLock(mutex)); return delegate.element(); } @Override
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 7.4K bytes - Viewed (0) -
LICENSES/vendor/github.com/google/cadvisor/third_party/containerd/NOTICE
It is your responsibility to ensure that your use and/or transfer does not violate applicable laws. For more information, please see https://www.bis.doc.gov
Plain Text - Registered: Fri Apr 26 09:05:10 GMT 2024 - Last Modified: Wed Aug 03 16:47:06 GMT 2022 - 519 bytes - Viewed (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/KotlinSourceModernTest.kt
@Test @Ignore fun dispatcherFromMockWebServer() { val dispatcher = object : Dispatcher() { override fun dispatch(request: RecordedRequest): MockResponse = TODO() override fun peek(): MockResponse = TODO() override fun shutdown() = TODO() } } @Test @Ignore fun mockResponse() { var mockResponse: MockResponse = MockResponse()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.3K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketWriter.kt
sinkBuffer.write(maskKey) if (length > 0) { val payloadStart = sinkBuffer.size sinkBuffer.write(payload) sinkBuffer.readAndWriteUnsafe(maskCursor!!) maskCursor.seek(payloadStart) toggleMask(maskCursor, maskKey) maskCursor.close() } } else { sinkBuffer.writeByte(b1) sinkBuffer.write(payload) } sink.flush() }
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) -
src/main/java/jcifs/smb/SmbPipeInputStream.java
* This stream class is unbuffered. Therefore this method will always * return 0 for streams connected to regular files. However, a * stream created from a Named Pipe this method will query the server using a * "peek named pipe" operation and return the number of available bytes * on the server. */ @Override public int available () throws IOException { try ( SmbFileHandleImpl fd = this.handle.ensureOpen();
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Aug 05 07:12:23 GMT 2018 - 3.5K bytes - Viewed (0) -
internal/s3select/select.go
return &ObjectReadSeekCloser{ segmentReader: segmentReader, size: actualSize, offset: 0, reader: nil, } } // Seek call to implement io.Seeker func (rsc *ObjectReadSeekCloser) Seek(offset int64, whence int) (int64, error) { // fmt.Printf("actual: %v offset: %v (%v) whence: %v\n", rsc.size, offset, rsc.offset, whence) switch whence { case io.SeekStart:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/Dispatcher.kt
* limitations under the License. */ package okhttp3.mockwebserver abstract class Dispatcher { @Throws(InterruptedException::class) abstract fun dispatch(request: RecordedRequest): MockResponse open fun peek(): MockResponse { return MockResponse().apply { this.socketPolicy = SocketPolicy.KEEP_OPEN } } open fun shutdown() {}
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Oct 18 12:55:43 GMT 2020 - 909 bytes - Viewed (0)