- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 95 for Dispatcher (0.2 sec)
-
android/guava/src/com/google/common/eventbus/Dispatcher.java
* * <p><b>Note:</b> The dispatcher is orthogonal to the subscriber's {@code Executor}. The dispatcher * controls the order in which events are dispatched, while the executor controls how (i.e. on which * thread) the subscriber is actually called when an event is dispatched to it. * * @author Colin Decker */ @ElementTypesAreNonnullByDefault abstract class Dispatcher { /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Dec 15 19:31:54 GMT 2023 - 7.3K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/Dispatcher.kt
* request bodies. */ open fun peek(): MockResponse { return MockResponse(socketPolicy = KeepOpen) } /** * Release any resources held by this dispatcher. Any requests that are currently being dispatched * should return immediately. Responses returned after shutdown will not be transmitted: their * socket connections have already been closed. */ open fun shutdown() {}
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 1.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
import okhttp3.internal.threadFactory /** * Policy on when async requests are executed. * * Each dispatcher uses an [ExecutorService] to run calls internally. If you supply your own * executor, it should be able to run [the configured maximum][maxRequests] number of calls * concurrently. */ class Dispatcher() { internal val lock: ReentrantLock = ReentrantLock() /**
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 9K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/Dispatcher.kt
* See the License for the specific language governing permissions and * 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 }
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) -
guava-tests/test/com/google/common/eventbus/DispatcherTest.java
Queues.newConcurrentLinkedQueue(); private Dispatcher dispatcher; public void testPerThreadQueuedDispatcher() { dispatcher = Dispatcher.perThreadDispatchQueue(); dispatcher.dispatch(1, integerSubscribers.iterator()); assertThat(dispatchedSubscribers) .containsExactly( i1, i2, i3, // Integer subscribers are dispatched to first. s1,
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Apr 27 15:41:25 GMT 2022 - 5.6K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/eventspy/internal/EventSpyExecutionListener.java
private final EventSpyDispatcher dispatcher; private final ExecutionListener delegate; EventSpyExecutionListener(EventSpyDispatcher dispatcher, ExecutionListener delegate) { this.dispatcher = dispatcher; this.delegate = delegate; } @Override public void projectDiscoveryStarted(ExecutionEvent event) { dispatcher.onEvent(event);
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Tue Nov 22 13:26:01 GMT 2022 - 3.9K bytes - Viewed (2) -
android/guava-tests/test/com/google/common/eventbus/DispatcherTest.java
Queues.newConcurrentLinkedQueue(); private Dispatcher dispatcher; public void testPerThreadQueuedDispatcher() { dispatcher = Dispatcher.perThreadDispatchQueue(); dispatcher.dispatch(1, integerSubscribers.iterator()); assertThat(dispatchedSubscribers) .containsExactly( i1, i2, i3, // Integer subscribers are dispatched to first. s1,
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 27 15:41:25 GMT 2022 - 5.6K bytes - Viewed (0) -
src/main/webapp/WEB-INF/web.xml
<url-pattern>/*</url-pattern> <dispatcher>REQUEST</dispatcher> <dispatcher>FORWARD</dispatcher><!-- TODO --> </filter-mapping> <filter-mapping> <filter-name>lastaPrepareFilter</filter-name> <url-pattern>/*</url-pattern> <dispatcher>REQUEST</dispatcher> <dispatcher>FORWARD</dispatcher> <dispatcher>INCLUDE</dispatcher> </filter-mapping> <filter-mapping>
XML - Registered: Mon Apr 22 08:04:10 GMT 2024 - Last Modified: Wed Feb 13 21:53:22 GMT 2019 - 7K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/eventspy/internal/EventSpyRepositoryListener.java
private final EventSpyDispatcher dispatcher; private final RepositoryListener delegate; EventSpyRepositoryListener(EventSpyDispatcher dispatcher, RepositoryListener delegate) { this.dispatcher = dispatcher; this.delegate = delegate; } @Override public void artifactDeployed(RepositoryEvent event) { dispatcher.onEvent(event); delegate.artifactDeployed(event);
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Tue Nov 22 13:26:01 GMT 2022 - 4.3K bytes - Viewed (0) -
mockwebserver/README.md
``` #### Dispatcher By default MockWebServer uses a queue to specify a series of responses. Use a Dispatcher (`import okhttp3.mockwebserver.Dispatcher`) to handle requests using another policy. One natural policy is to dispatch on the request path. You can, for example, filter the request instead of using `server.enqueue()`. ```java final Dispatcher dispatcher = new Dispatcher() { @Override
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Dec 17 15:34:10 GMT 2023 - 5K bytes - Viewed (1)