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