@Test public void offloadSendPublisher() throws Exception { ThreadAnalyzer analyzer = new ThreadAnalyzer(); analyzer.instrumentSend(strategy.offloadSend(executor, from(1))).toFuture().get(); analyzer.verifySend(); }
@Override public <T> Single<T> offloadSend(final Executor fallback, final Single<T> original) { return offloaded(OFFLOAD_SEND) ? original.subscribeOn(executor(fallback)) : original; }
DefaultHttpExecutionStrategy implements HttpExecutionStrategy { @Override public <T> Single<T> offloadSend(final Executor fallback, final Single<T> original) { return offloaded(OFFLOAD_SEND) ? original.subscribeOn(executor(fallback)) : original; } }
DefaultHttpExecutionStrategy implements HttpExecutionStrategy { @Override public <T> Single<T> offloadSend(final Executor fallback, final Single<T> original) { return offloaded(OFFLOAD_SEND) ? original.subscribeOn(executor(fallback)) : original; } DefaultHttpExecutionStrategy(@Nullable final Executor executor, final byte offloads, final boolean threadAffinity,
                                 final MergeStrategy mergeStrategy);   DefaultHttpExecutionStrategy(byte offloadOverride, HttpExecutionStrategy original); }
DefaultHttpExecutionStrategy implements HttpExecutionStrategy { @Override public <T> Single<T> offloadSend(final Executor fallback, final Single<T> original) { return offloaded(OFFLOAD_SEND) ? original.subscribeOn(executor(fallback)) : original; } DefaultHttpExecutionStrategy(@Nullable final Executor executor, final byte offloads, final boolean threadAffinity,
                                 final MergeStrategy mergeStrategy);   DefaultHttpExecutionStrategy(byte offloadOverride, HttpExecutionStrategy original); @Nullable @Override Executor executor(); @Override Single<StreamingHttpResponse> invokeClient(
            final Executor fallback, Publisher<Object> flattenedRequest, @Nullable final FS flushStrategy,
            final ClientInvoker<FS> client); @Override Publisher<Object> invokeService(
            final Executor fallback, StreamingHttpRequest request,
            final Function<StreamingHttpRequest, Publisher<Object>> service,
            final BiFunction<Throwable, Executor, Publisher<Object>> errorHandler); @Override StreamingHttpService offloadService(final Executor fallback, final StreamingHttpService service); @Override boolean isMetadataReceiveOffloaded(); @Override boolean isDataReceiveOffloaded(); @Override boolean isSendOffloaded(); @Override HttpExecutionStrategy merge(final HttpExecutionStrategy other); @Override Single<T> invokeService(final Executor fallback, final Function<Executor, T> service); @Override Single<T> offloadSend(final Executor fallback, final Single<T> original); @Override Single<T> offloadReceive(final Executor fallback, final Single<T> original); @Override Publisher<T> offloadSend(final Executor fallback, final Publisher<T> original); @Override Publisher<T> offloadReceive(final Executor fallback, final Publisher<T> original); @Override boolean equals(final Object o); @Override int hashCode(); @Override String toString(); }
DefaultHttpExecutionStrategy implements HttpExecutionStrategy { @Override public <T> Single<T> offloadSend(final Executor fallback, final Single<T> original) { return offloaded(OFFLOAD_SEND) ? original.subscribeOn(executor(fallback)) : original; } DefaultHttpExecutionStrategy(@Nullable final Executor executor, final byte offloads, final boolean threadAffinity,
                                 final MergeStrategy mergeStrategy);   DefaultHttpExecutionStrategy(byte offloadOverride, HttpExecutionStrategy original); @Nullable @Override Executor executor(); @Override Single<StreamingHttpResponse> invokeClient(
            final Executor fallback, Publisher<Object> flattenedRequest, @Nullable final FS flushStrategy,
            final ClientInvoker<FS> client); @Override Publisher<Object> invokeService(
            final Executor fallback, StreamingHttpRequest request,
            final Function<StreamingHttpRequest, Publisher<Object>> service,
            final BiFunction<Throwable, Executor, Publisher<Object>> errorHandler); @Override StreamingHttpService offloadService(final Executor fallback, final StreamingHttpService service); @Override boolean isMetadataReceiveOffloaded(); @Override boolean isDataReceiveOffloaded(); @Override boolean isSendOffloaded(); @Override HttpExecutionStrategy merge(final HttpExecutionStrategy other); @Override Single<T> invokeService(final Executor fallback, final Function<Executor, T> service); @Override Single<T> offloadSend(final Executor fallback, final Single<T> original); @Override Single<T> offloadReceive(final Executor fallback, final Single<T> original); @Override Publisher<T> offloadSend(final Executor fallback, final Publisher<T> original); @Override Publisher<T> offloadReceive(final Executor fallback, final Publisher<T> original); @Override boolean equals(final Object o); @Override int hashCode(); @Override String toString();  }