@RequestScoped
public class CustomBean {
    public String get() {
        return "message from custom bean";
    }
}

@Path("/")
@RequestScoped
public class TestResource {

    @Inject
    CustomBean bean;
    
    @Path("a")
    @GET
    public CompletionStage<Response> a() {
        ExecutorService executor = Executors.newSingleThreadExecutor();
        CompletableFuture<Response> resp = new CompletableFuture<>();
        executor.submit(() -> {
            System.out.println(bean.get());
            resp.complete(Response.ok("a").build());
        });
        return resp;
    }

    @GET
    @Path("c")
    @Produces(MediaType.APPLICATION_JSON)
    @Stream(Stream.MODE.GENERAL)
    public Flowable<String> multiThreadRx() {
        System.out.println("get: " + Thread.currentThread().toString());
        return Flowable.create(new FlowableOnSubscribe<String>() {

            @Override
            public void subscribe(FlowableEmitter<String> emitter) throws Exception {
				System.out.println(bean.get());
				System.out.println("emmiter: " + Thread.currentThread().toString());
				for (Integer i = 0; i < 5; i++) {
					emitter.onNext("some string " + i);
				}
				emitter.onComplete();
			}}, BackpressureStrategy.BUFFER).subscribeOn(Schedulers.newThread())
		.observeOn(Schedulers.newThread());
    }
}

    @GET
    @Path("e")
    @Produces("text/plain")
    public CompletionStage<String> e(@Context HttpRequest req) {
        System.out.println("request (inline): " + req);
        System.out.println("application (inline): " + ResteasyContext.getContextData(Application.class));
        CompletableFuture<String> cs = new CompletableFuture<>();
        ExecutorService executor = Executors.newSingleThreadExecutor();
        executor.submit(
                io.reactiverse.reactivecontexts.core.Context.wrap(new Runnable() {
                    public void run() {
                        try {
                            System.out.println("request (async): " + req);
                            System.out.println(bean.get());
                            System.out.println("application (async): " + ResteasyContext.getContextData(Application.class));
                            cs.complete("hello");
                        } catch (Exception e) {
                            e.printStackTrace();
                        }
                    }
                }));
        return cs;
    }