Searched refs:frobnicateWrapper (Results 1 – 7 of 7) sorted by relevance
145 return FutureUtil.transform(frobnicateWrapper(rpcOptions)); in frobnicate()150 return FutureUtil.transform(frobnicateWrapper(RpcOptions.EMPTY)); in frobnicate()154 public ListenableFuture<ResponseWrapper<Integer>> frobnicateWrapper( in frobnicateWrapper() method in MyServiceAsyncClientImpl.MyInteractionImpl218 return FutureUtil.transform(frobnicateWrapper(rpcOptions)); in frobnicate()223 return FutureUtil.transform(frobnicateWrapper(RpcOptions.EMPTY)); in frobnicate()227 public ListenableFuture<ResponseWrapper<Integer>> frobnicateWrapper( in frobnicateWrapper() method in MyServiceAsyncClientImpl.MyInteractionFastImpl291 return FutureUtil.transform(frobnicateWrapper(rpcOptions)); in frobnicate()296 return FutureUtil.transform(frobnicateWrapper(RpcOptions.EMPTY)); in frobnicate()300 public ListenableFuture<ResponseWrapper<Void>> frobnicateWrapper( in frobnicateWrapper() method in MyServiceAsyncClientImpl.SerialInteractionImpl
48 ListenableFuture<ResponseWrapper<Integer>> frobnicateWrapper( in frobnicateWrapper() method74 ListenableFuture<ResponseWrapper<Integer>> frobnicateWrapper( in frobnicateWrapper() method100 ListenableFuture<ResponseWrapper<Void>> frobnicateWrapper( in frobnicateWrapper() method147 … reactor.core.publisher.Mono<ResponseWrapper<Integer>> frobnicateWrapper(RpcOptions rpcOptions); in frobnicateWrapper() method180 … reactor.core.publisher.Mono<ResponseWrapper<Integer>> frobnicateWrapper(RpcOptions rpcOptions); in frobnicateWrapper() method213 … reactor.core.publisher.Mono<ResponseWrapper<Void>> frobnicateWrapper(RpcOptions rpcOptions); in frobnicateWrapper() method232 ResponseWrapper<Integer> frobnicateWrapper( in frobnicateWrapper() method258 ResponseWrapper<Integer> frobnicateWrapper( in frobnicateWrapper() method284 ResponseWrapper<Void> frobnicateWrapper( in frobnicateWrapper() method
146 return frobnicateWrapper(RpcOptions.EMPTY).getData(); in frobnicate()151 return frobnicateWrapper(rpcOptions).getData(); in frobnicate()154 public ResponseWrapper<Integer> frobnicateWrapper( in frobnicateWrapper() method in MyServiceClientImpl.MyInteractionImpl224 return frobnicateWrapper(RpcOptions.EMPTY).getData(); in frobnicate()229 return frobnicateWrapper(rpcOptions).getData(); in frobnicate()232 public ResponseWrapper<Integer> frobnicateWrapper( in frobnicateWrapper() method in MyServiceClientImpl.MyInteractionFastImpl299 frobnicateWrapper(RpcOptions.EMPTY).getData(); in frobnicate()304 frobnicateWrapper(rpcOptions).getData(); in frobnicate()307 public ResponseWrapper<Void> frobnicateWrapper( in frobnicateWrapper() method in MyServiceClientImpl.SerialInteractionImpl
47 …public reactor.core.publisher.Mono<ResponseWrapper<Integer>> frobnicateWrapper(RpcOptions rpcOptio… in frobnicateWrapper() method in MyServiceAsyncReactiveWrapper.MyInteractionImpl48 …urn com.facebook.thrift.util.FutureUtil.toMono(_delegateInteraction.frobnicateWrapper( rpcOptions)… in frobnicateWrapper()93 …public reactor.core.publisher.Mono<ResponseWrapper<Integer>> frobnicateWrapper(RpcOptions rpcOptio… in frobnicateWrapper() method in MyServiceAsyncReactiveWrapper.MyInteractionFastImpl94 …urn com.facebook.thrift.util.FutureUtil.toMono(_delegateInteraction.frobnicateWrapper( rpcOptions)… in frobnicateWrapper()139 …public reactor.core.publisher.Mono<ResponseWrapper<Void>> frobnicateWrapper(RpcOptions rpcOptions)… in frobnicateWrapper() method in MyServiceAsyncReactiveWrapper.SerialInteractionImpl140 …urn com.facebook.thrift.util.FutureUtil.toMono(_delegateInteraction.frobnicateWrapper( rpcOptions)… in frobnicateWrapper()
62 …public reactor.core.publisher.Mono<ResponseWrapper<Integer>> frobnicateWrapper(RpcOptions rpcOptio…124 …public reactor.core.publisher.Mono<ResponseWrapper<Integer>> frobnicateWrapper(RpcOptions rpcOptio…186 …public reactor.core.publisher.Mono<ResponseWrapper<Void>> frobnicateWrapper(RpcOptions rpcOptions)…
60 …concurrent.ListenableFuture<com.facebook.thrift.client.ResponseWrapper<Integer>> frobnicateWrapper( in frobnicateWrapper() method in MyServiceReactiveAsyncWrapper.MyInteractionImpl103 …concurrent.ListenableFuture<com.facebook.thrift.client.ResponseWrapper<Integer>> frobnicateWrapper( in frobnicateWrapper() method in MyServiceReactiveAsyncWrapper.MyInteractionFastImpl146 …il.concurrent.ListenableFuture<com.facebook.thrift.client.ResponseWrapper<Void>> frobnicateWrapper( in frobnicateWrapper() method in MyServiceReactiveAsyncWrapper.SerialInteractionImpl
181 … return frobnicateWrapper( com.facebook.thrift.client.RpcOptions.EMPTY).map(_p -> _p.getData());186 return frobnicateWrapper( rpcOptions).map(_p -> _p.getData());190 …public reactor.core.publisher.Mono<ResponseWrapper<Integer>> frobnicateWrapper(RpcOptions rpcOptio…421 … return frobnicateWrapper( com.facebook.thrift.client.RpcOptions.EMPTY).map(_p -> _p.getData());426 return frobnicateWrapper( rpcOptions).map(_p -> _p.getData());430 …public reactor.core.publisher.Mono<ResponseWrapper<Integer>> frobnicateWrapper(RpcOptions rpcOptio…659 return frobnicateWrapper( com.facebook.thrift.client.RpcOptions.EMPTY).then();664 return frobnicateWrapper( rpcOptions).then();668 …public reactor.core.publisher.Mono<ResponseWrapper<Void>> frobnicateWrapper(RpcOptions rpcOptions)…