- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for queueDispatcher (4.92 sec)
-
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/QueueDispatcher.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.mockwebserver import mockwebserver3.QueueDispatcher class QueueDispatcher : Dispatcher() { internal val delegate = QueueDispatcher() @Throws(InterruptedException::class) override fun dispatch(request: RecordedRequest): MockResponse { throw UnsupportedOperationException("unexpected call") }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Oct 18 12:55:43 GMT 2020 - 1.3K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/QueueDispatcher.kt
import okhttp3.ExperimentalOkHttpApi /** * Default dispatcher that processes a script of responses. Populate the script by calling [enqueueResponse]. */ @ExperimentalOkHttpApi open class QueueDispatcher : Dispatcher() { protected val responseQueue: BlockingQueue<MockResponse> = LinkedBlockingQueue() private var failFastResponse: MockResponse? = null @Throws(InterruptedException::class)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 3K bytes - Viewed (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/KotlinSourceModernTest.kt
} @Test @Ignore fun queueDispatcher() { val queueDispatcher: QueueDispatcher = QueueDispatcher() var mockResponse: MockResponse = queueDispatcher.dispatch( RecordedRequest("", headersOf(), listOf(), 0L, Buffer(), 0, Socket()), ) mockResponse = queueDispatcher.peek() queueDispatcher.enqueueResponse(MockResponse()) queueDispatcher.shutdown()
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) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt
import mockwebserver3.SocketPolicy.ShutdownServerAfterResponse import mockwebserver3.SocketPolicy.StallSocketAtStart internal fun Dispatcher.wrap(): mockwebserver3.Dispatcher { if (this is QueueDispatcher) return this.delegate val delegate = this return object : mockwebserver3.Dispatcher() { override fun dispatch(request: mockwebserver3.RecordedRequest): 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) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockWebServer.kt
val requestCount: Int by delegate::requestCount var bodyLimit: Long by delegate::bodyLimit var serverSocketFactory: ServerSocketFactory? by delegate::serverSocketFactory var dispatcher: Dispatcher = QueueDispatcher() set(value) { field = value delegate.dispatcher = value.wrap() } val port: Int get() { before() // This implicitly starts the delegate. return delegate.port
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 5.9K bytes - Viewed (0)