- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 310 for peek (0.26 sec)
-
src/cmd/asm/internal/lex/tokenizer.go
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Aug 04 20:35:21 GMT 2022 - 3K bytes - Viewed (0) -
src/cmd/asm/internal/asm/parse.go
doIssueError := true isStatic, abi := p.symRefAttrs(name, doIssueError) if p.peek() == '+' || p.peek() == '-' { a.Offset = int64(p.expr()) } if isStatic { a.Sym = p.ctxt.LookupStatic(name) } else { a.Sym = p.ctxt.LookupABI(name, abi) } if p.peek() == scanner.EOF { if prefix == 0 && p.isJump { // Symbols without prefix or suffix are jump labels. return }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Feb 21 14:34:57 GMT 2024 - 36.9K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
) { chunked = true } } val peek = dispatcher.peek() for (response in peek.informationalResponses) { writeHttpResponse(socket, sink, response) } var hasBody = false val policy = dispatcher.peek() val requestBodySink = requestBody.withThrottlingAndSocketPolicy( policy = policy,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K 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 Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K 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 Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.3K bytes - Viewed (1) -
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) -
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 Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Oct 18 12:55:43 GMT 2020 - 909 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 Apr 28 00:10:09 GMT 2024 - Last Modified: Sun Aug 05 07:12:23 GMT 2018 - 3.5K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/ioctl/Smb2IoctlResponse.java
&& ! ( status == NtStatus.NT_STATUS_BUFFER_OVERFLOW && ( this.ctlCode == Smb2IoctlRequest.FSCTL_PIPE_TRANSCEIVE || this.ctlCode == Smb2IoctlRequest.FSCTL_PIPE_PEEK || this.ctlCode == Smb2IoctlRequest.FSCTL_DFS_GET_REFERRALS ) ) && super.isErrorResponseStatus(); } /** * {@inheritDoc} *
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Sun Aug 05 09:45:59 GMT 2018 - 7.4K 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)