1 /**
2  * Autogenerated by Thrift
3  *
4  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
5  *  @generated
6  */
7 
8 package test.fixtures.includes;
9 
10 import com.facebook.thrift.client.*;
11 import java.util.*;
12 
13 public class MyServiceAsyncReactiveWrapper
14     implements MyService.Reactive {
15     private final MyService.Async _delegate;
16 
MyServiceAsyncReactiveWrapper(MyService.Async _delegate)17     public MyServiceAsyncReactiveWrapper(MyService.Async _delegate) {
18 
19         this._delegate = _delegate;
20     }
21 
22     @java.lang.Override
dispose()23     public void dispose() {
24         _delegate.close();
25     }
26 
27     @java.lang.Override
query(final test.fixtures.includes.MyStruct s, final test.fixtures.includes.includes.Included i)28     public reactor.core.publisher.Mono<Void> query(final test.fixtures.includes.MyStruct s, final test.fixtures.includes.includes.Included i) {
29         return com.facebook.thrift.util.FutureUtil.toMono(_delegate.query(s, i));
30     }
31 
32     @java.lang.Override
hasArgDocs(final test.fixtures.includes.MyStruct s, final test.fixtures.includes.includes.Included i)33     public reactor.core.publisher.Mono<Void> hasArgDocs(final test.fixtures.includes.MyStruct s, final test.fixtures.includes.includes.Included i) {
34         return com.facebook.thrift.util.FutureUtil.toMono(_delegate.hasArgDocs(s, i));
35     }
36 
37 }
38