View Javadoc
1   package com.github.davidmoten.rx;
2   
3   import java.util.List;
4   
5   import javax.xml.bind.annotation.adapters.XmlAdapter;
6   
7   import rx.Observable;
8   
9   public class Jaxws {
10  
11      @SuppressWarnings("rawtypes")
12      public static final class ObservableAdapter extends XmlAdapter<List, Observable> {
13  
14          @SuppressWarnings({ "unchecked" })
15          @Override
16          public Observable unmarshal(List list) throws Exception {
17              return Observable.from(list);
18          }
19  
20          @Override
21          public List marshal(Observable o) throws Exception {
22              return (List) o.toList().toBlocking().single();
23          }
24  
25      }
26  
27  }