...
The following simple example uses FlowableRxInvokerObservableRxInvoker. org.apache.cxf.jaxrs.rx2.client.ObservableRxInvoker FlowableRxInvoker can be used if needed instead. Reviewing our systests for reactive may help as well.
Code Block | ||
---|---|---|
| ||
@Test public void testGetHelloWorldJson() throws Exception { String address = "http://localhost:" + PORT + "/rx2/observable/textJson"; List<Object> providers = new LinkedList<>(); providers.add(new JacksonJsonProvider()); providers.add(new ObservableRxInvokerProvider()); WebClient wc = WebClient.create(address, providers); Observable<HelloWorldBean> obs = wc.accept("application/json") .rx(ObservableRxInvoker.class) .get(HelloWorldBean.class); Holder<HelloWorldBean> holder = new Holder<HelloWorldBean>(); obs.subscribe(v -> { holder.value = v; }); Thread.sleep(2000); assertEquals("Hello", holder.value.getGreeting()); assertEquals("World", holder.value.getAudience()); } |
Server
As a method return value
...