### Question:
DefaultHttpExecutionStrategy implements HttpExecutionStrategy { @Override public <T> Single<T> offloadReceive(final Executor fallback, final Single<T> original) { return offloaded(OFFLOAD_RECEIVE_META) || offloaded(OFFLOAD_RECEIVE_DATA) ? original.publishOn(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();  }### Answer:
@Test public void offloadReceiveSingle() throws Exception { ThreadAnalyzer analyzer = new ThreadAnalyzer(); analyzer.instrumentReceive(strategy.offloadReceive(executor, succeeded(1))).toFuture().get(); analyzer.verifyReceive(); }
@Test public void offloadReceivePublisher() throws Exception { ThreadAnalyzer analyzer = new ThreadAnalyzer(); analyzer.instrumentReceive(strategy.offloadReceive(executor, from(1))).toFuture().get(); analyzer.verifyReceive(); }