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.basic;
9 
10 import static com.facebook.swift.service.SwiftConstants.STICKY_HASH_KEY;
11 
12 import java.util.*;
13 import java.util.concurrent.ConcurrentHashMap;
14 import java.util.concurrent.atomic.AtomicLong;
15 import org.apache.thrift.protocol.*;
16 import org.apache.thrift.ClientPushMetadata;
17 import org.apache.thrift.InteractionCreate;
18 import org.apache.thrift.InteractionTerminate;
19 import com.facebook.thrift.client.ResponseWrapper;
20 import com.facebook.thrift.client.RpcOptions;
21 
22 public class MyServiceReactiveClient
23   implements MyService.Reactive {
24   private static final AtomicLong _interactionCounter = new AtomicLong(0);
25 
26   private final org.apache.thrift.ProtocolId _protocolId;
27   private final reactor.core.publisher.Mono<? extends com.facebook.thrift.client.RpcClient> _rpcClient;
28   private final Map<String, String> _headers;
29   private final Map<String, String> _persistentHeaders;
30   private final Set<Long> _activeInteractions;
31 
32   private static final java.util.Map<Short, com.facebook.thrift.payload.Reader> _ping_EXCEPTION_READERS = java.util.Collections.emptyMap();
33   private static final java.util.Map<Short, com.facebook.thrift.payload.Reader> _getRandomData_EXCEPTION_READERS = java.util.Collections.emptyMap();
34   private static final TField _sink_SINK_FIELD_DESC = new TField("sink", TType.I64, (short)1);
35   private static final java.util.Map<Short, com.facebook.thrift.payload.Reader> _sink_EXCEPTION_READERS = java.util.Collections.emptyMap();
36   private static final TField _putDataById_ID_FIELD_DESC = new TField("id", TType.I64, (short)1);
37   private static final TField _putDataById_DATA_FIELD_DESC = new TField("data", TType.STRING, (short)2);
38   private static final java.util.Map<Short, com.facebook.thrift.payload.Reader> _putDataById_EXCEPTION_READERS = java.util.Collections.emptyMap();
39   private static final TField _hasDataById_ID_FIELD_DESC = new TField("id", TType.I64, (short)1);
40   private static final java.util.Map<Short, com.facebook.thrift.payload.Reader> _hasDataById_EXCEPTION_READERS = java.util.Collections.emptyMap();
41   private static final TField _getDataById_ID_FIELD_DESC = new TField("id", TType.I64, (short)1);
42   private static final java.util.Map<Short, com.facebook.thrift.payload.Reader> _getDataById_EXCEPTION_READERS = java.util.Collections.emptyMap();
43   private static final TField _deleteDataById_ID_FIELD_DESC = new TField("id", TType.I64, (short)1);
44   private static final java.util.Map<Short, com.facebook.thrift.payload.Reader> _deleteDataById_EXCEPTION_READERS = java.util.Collections.emptyMap();
45   private static final TField _lobDataById_ID_FIELD_DESC = new TField("id", TType.I64, (short)1);
46   private static final TField _lobDataById_DATA_FIELD_DESC = new TField("data", TType.STRING, (short)2);
47   private static final java.util.Map<Short, com.facebook.thrift.payload.Reader> _lobDataById_EXCEPTION_READERS = java.util.Collections.emptyMap();
48 
49   static {
50   }
51 
MyServiceReactiveClient(org.apache.thrift.ProtocolId _protocolId, reactor.core.publisher.Mono<? extends com.facebook.thrift.client.RpcClient> _rpcClient)52   public MyServiceReactiveClient(org.apache.thrift.ProtocolId _protocolId, reactor.core.publisher.Mono<? extends com.facebook.thrift.client.RpcClient> _rpcClient) {
53 
54     this._protocolId = _protocolId;
55     this._rpcClient = _rpcClient;
56     this._headers = java.util.Collections.emptyMap();
57     this._persistentHeaders = java.util.Collections.emptyMap();
58     this._activeInteractions = ConcurrentHashMap.newKeySet();
59   }
60 
MyServiceReactiveClient(org.apache.thrift.ProtocolId _protocolId, reactor.core.publisher.Mono<? extends com.facebook.thrift.client.RpcClient> _rpcClient, Map<String, String> _headers, Map<String, String> _persistentHeaders)61   public MyServiceReactiveClient(org.apache.thrift.ProtocolId _protocolId, reactor.core.publisher.Mono<? extends com.facebook.thrift.client.RpcClient> _rpcClient, Map<String, String> _headers, Map<String, String> _persistentHeaders) {
62     this(_protocolId, _rpcClient, _headers, _persistentHeaders, new AtomicLong(), ConcurrentHashMap.newKeySet());
63   }
64 
MyServiceReactiveClient(org.apache.thrift.ProtocolId _protocolId, reactor.core.publisher.Mono<? extends com.facebook.thrift.client.RpcClient> _rpcClient, Map<String, String> _headers, Map<String, String> _persistentHeaders, AtomicLong interactionCounter, Set<Long> activeInteractions)65   public MyServiceReactiveClient(org.apache.thrift.ProtocolId _protocolId, reactor.core.publisher.Mono<? extends com.facebook.thrift.client.RpcClient> _rpcClient, Map<String, String> _headers, Map<String, String> _persistentHeaders, AtomicLong interactionCounter, Set<Long> activeInteractions) {
66 
67     this._protocolId = _protocolId;
68     this._rpcClient = _rpcClient;
69     this._headers = _headers;
70     this._persistentHeaders = _persistentHeaders;
71     this._activeInteractions = activeInteractions;
72   }
73 
74   @java.lang.Override
dispose()75   public void dispose() {}
76 
_createpingWriter()77   private com.facebook.thrift.payload.Writer _createpingWriter() {
78     return oprot -> {
79       try {
80 
81       } catch (Throwable _e) {
82         throw reactor.core.Exceptions.propagate(_e);
83       }
84     };
85   }
86 
87   private static final com.facebook.thrift.payload.Reader _ping_READER =
88     oprot -> {
89               try {
90 
91                 return null;
92 
93               } catch (Throwable _e) {
94                 throw reactor.core.Exceptions.propagate(_e);
95               }
96             };
97 
98 
99   @java.lang.Override
100   public reactor.core.publisher.Mono<com.facebook.thrift.client.ResponseWrapper<Void>> pingWrapper( final com.facebook.thrift.client.RpcOptions rpcOptions) {
101     return _rpcClient
102       .flatMap(_rpc -> {
103         org.apache.thrift.RequestRpcMetadata _metadata = new org.apache.thrift.RequestRpcMetadata.Builder()
104                 .setName("ping")
105                 .setKind(org.apache.thrift.RpcKind.SINGLE_REQUEST_SINGLE_RESPONSE)
106                 .setOtherMetadata(getHeaders(rpcOptions))
107                 .setProtocol(_protocolId)
108                 .build();
109 
110             com.facebook.thrift.payload.ClientRequestPayload<Void> _crp =
111                 com.facebook.thrift.payload.ClientRequestPayload.create(
112                     _createpingWriter(),
113                     _ping_READER,
114                     _ping_EXCEPTION_READERS,
115                     _metadata,
116                     java.util.Collections.emptyMap());
117 
118             return _rpc
119                 .singleRequestSingleResponse(_crp, rpcOptions).doOnNext(_p -> {if(_p.getException() != null) throw reactor.core.Exceptions.propagate(_p.getException());});
120       });
121   }
122 
123   @java.lang.Override
124   public reactor.core.publisher.Mono<Void> ping( final com.facebook.thrift.client.RpcOptions rpcOptions) {
125     return pingWrapper( rpcOptions).then();
126   }
127 
128   @java.lang.Override
129   public reactor.core.publisher.Mono<Void> ping() {
130     return ping( com.facebook.thrift.client.RpcOptions.EMPTY);
131   }
132 
133   private com.facebook.thrift.payload.Writer _creategetRandomDataWriter() {
134     return oprot -> {
135       try {
136 
137       } catch (Throwable _e) {
138         throw reactor.core.Exceptions.propagate(_e);
139       }
140     };
141   }
142 
143   private static final com.facebook.thrift.payload.Reader _getRandomData_READER =
144     oprot -> {
145               try {
146                 String _r = oprot.readString();
147                 return _r;
148 
149 
150               } catch (Throwable _e) {
151                 throw reactor.core.Exceptions.propagate(_e);
152               }
153             };
154 
155 
156   @java.lang.Override
157   public reactor.core.publisher.Mono<com.facebook.thrift.client.ResponseWrapper<String>> getRandomDataWrapper( final com.facebook.thrift.client.RpcOptions rpcOptions) {
158     return _rpcClient
159       .flatMap(_rpc -> {
160         org.apache.thrift.RequestRpcMetadata _metadata = new org.apache.thrift.RequestRpcMetadata.Builder()
161                 .setName("getRandomData")
162                 .setKind(org.apache.thrift.RpcKind.SINGLE_REQUEST_SINGLE_RESPONSE)
163                 .setOtherMetadata(getHeaders(rpcOptions))
164                 .setProtocol(_protocolId)
165                 .build();
166 
167             com.facebook.thrift.payload.ClientRequestPayload<String> _crp =
168                 com.facebook.thrift.payload.ClientRequestPayload.create(
169                     _creategetRandomDataWriter(),
170                     _getRandomData_READER,
171                     _getRandomData_EXCEPTION_READERS,
172                     _metadata,
173                     java.util.Collections.emptyMap());
174 
175             return _rpc
176                 .singleRequestSingleResponse(_crp, rpcOptions).doOnNext(_p -> {if(_p.getException() != null) throw reactor.core.Exceptions.propagate(_p.getException());});
177       });
178   }
179 
180   @java.lang.Override
181   public reactor.core.publisher.Mono<String> getRandomData( final com.facebook.thrift.client.RpcOptions rpcOptions) {
182     return getRandomDataWrapper( rpcOptions).map(_p -> _p.getData());
183   }
184 
185   @java.lang.Override
186   public reactor.core.publisher.Mono<String> getRandomData() {
187     return getRandomData( com.facebook.thrift.client.RpcOptions.EMPTY);
188   }
189 
190   private com.facebook.thrift.payload.Writer _createsinkWriter(final long sink) {
191     return oprot -> {
192       try {
193         {
194           oprot.writeFieldBegin(_sink_SINK_FIELD_DESC);
195 
196           long _iter0 = sink;
197 
198           oprot.writeI64(sink);
199           oprot.writeFieldEnd();
200         }
201 
202 
203       } catch (Throwable _e) {
204         throw reactor.core.Exceptions.propagate(_e);
205       }
206     };
207   }
208 
209   private static final com.facebook.thrift.payload.Reader _sink_READER =
210     oprot -> {
211               try {
212 
213                 return null;
214 
215               } catch (Throwable _e) {
216                 throw reactor.core.Exceptions.propagate(_e);
217               }
218             };
219 
220 
221   @java.lang.Override
222   public reactor.core.publisher.Mono<com.facebook.thrift.client.ResponseWrapper<Void>> sinkWrapper(final long sink,  final com.facebook.thrift.client.RpcOptions rpcOptions) {
223     return _rpcClient
224       .flatMap(_rpc -> {
225         org.apache.thrift.RequestRpcMetadata _metadata = new org.apache.thrift.RequestRpcMetadata.Builder()
226                 .setName("sink")
227                 .setKind(org.apache.thrift.RpcKind.SINGLE_REQUEST_SINGLE_RESPONSE)
228                 .setOtherMetadata(getHeaders(rpcOptions))
229                 .setProtocol(_protocolId)
230                 .build();
231 
232             com.facebook.thrift.payload.ClientRequestPayload<Void> _crp =
233                 com.facebook.thrift.payload.ClientRequestPayload.create(
234                     _createsinkWriter(sink),
235                     _sink_READER,
236                     _sink_EXCEPTION_READERS,
237                     _metadata,
238                     java.util.Collections.emptyMap());
239 
240             return _rpc
241                 .singleRequestSingleResponse(_crp, rpcOptions).doOnNext(_p -> {if(_p.getException() != null) throw reactor.core.Exceptions.propagate(_p.getException());});
242       });
243   }
244 
245   @java.lang.Override
246   public reactor.core.publisher.Mono<Void> sink(final long sink,  final com.facebook.thrift.client.RpcOptions rpcOptions) {
247     return sinkWrapper(sink,  rpcOptions).then();
248   }
249 
250   @java.lang.Override
251   public reactor.core.publisher.Mono<Void> sink(final long sink) {
252     return sink(sink,  com.facebook.thrift.client.RpcOptions.EMPTY);
253   }
254 
255   private com.facebook.thrift.payload.Writer _createputDataByIdWriter(final long id, final String data) {
256     return oprot -> {
257       try {
258         {
259           oprot.writeFieldBegin(_putDataById_ID_FIELD_DESC);
260 
261           long _iter0 = id;
262 
263           oprot.writeI64(id);
264           oprot.writeFieldEnd();
265         }
266 
267         {
268           oprot.writeFieldBegin(_putDataById_DATA_FIELD_DESC);
269 
270           String _iter0 = data;
271 
272           oprot.writeString(data);
273           oprot.writeFieldEnd();
274         }
275 
276 
277       } catch (Throwable _e) {
278         throw reactor.core.Exceptions.propagate(_e);
279       }
280     };
281   }
282 
283   private static final com.facebook.thrift.payload.Reader _putDataById_READER =
284     oprot -> {
285               try {
286 
287                 return null;
288 
289               } catch (Throwable _e) {
290                 throw reactor.core.Exceptions.propagate(_e);
291               }
292             };
293 
294 
295   @java.lang.Override
296   public reactor.core.publisher.Mono<com.facebook.thrift.client.ResponseWrapper<Void>> putDataByIdWrapper(final long id, final String data,  final com.facebook.thrift.client.RpcOptions rpcOptions) {
297     return _rpcClient
298       .flatMap(_rpc -> {
299         org.apache.thrift.RequestRpcMetadata _metadata = new org.apache.thrift.RequestRpcMetadata.Builder()
300                 .setName("putDataById")
301                 .setKind(org.apache.thrift.RpcKind.SINGLE_REQUEST_SINGLE_RESPONSE)
302                 .setOtherMetadata(getHeaders(rpcOptions))
303                 .setProtocol(_protocolId)
304                 .build();
305 
306             com.facebook.thrift.payload.ClientRequestPayload<Void> _crp =
307                 com.facebook.thrift.payload.ClientRequestPayload.create(
308                     _createputDataByIdWriter(id, data),
309                     _putDataById_READER,
310                     _putDataById_EXCEPTION_READERS,
311                     _metadata,
312                     java.util.Collections.emptyMap());
313 
314             return _rpc
315                 .singleRequestSingleResponse(_crp, rpcOptions).doOnNext(_p -> {if(_p.getException() != null) throw reactor.core.Exceptions.propagate(_p.getException());});
316       });
317   }
318 
319   @java.lang.Override
320   public reactor.core.publisher.Mono<Void> putDataById(final long id, final String data,  final com.facebook.thrift.client.RpcOptions rpcOptions) {
321     return putDataByIdWrapper(id, data,  rpcOptions).then();
322   }
323 
324   @java.lang.Override
325   public reactor.core.publisher.Mono<Void> putDataById(final long id, final String data) {
326     return putDataById(id, data,  com.facebook.thrift.client.RpcOptions.EMPTY);
327   }
328 
329   private com.facebook.thrift.payload.Writer _createhasDataByIdWriter(final long id) {
330     return oprot -> {
331       try {
332         {
333           oprot.writeFieldBegin(_hasDataById_ID_FIELD_DESC);
334 
335           long _iter0 = id;
336 
337           oprot.writeI64(id);
338           oprot.writeFieldEnd();
339         }
340 
341 
342       } catch (Throwable _e) {
343         throw reactor.core.Exceptions.propagate(_e);
344       }
345     };
346   }
347 
348   private static final com.facebook.thrift.payload.Reader _hasDataById_READER =
349     oprot -> {
350               try {
351                 boolean _r = oprot.readBool();
352                 return _r;
353 
354 
355               } catch (Throwable _e) {
356                 throw reactor.core.Exceptions.propagate(_e);
357               }
358             };
359 
360 
361   @java.lang.Override
362   public reactor.core.publisher.Mono<com.facebook.thrift.client.ResponseWrapper<Boolean>> hasDataByIdWrapper(final long id,  final com.facebook.thrift.client.RpcOptions rpcOptions) {
363     return _rpcClient
364       .flatMap(_rpc -> {
365         org.apache.thrift.RequestRpcMetadata _metadata = new org.apache.thrift.RequestRpcMetadata.Builder()
366                 .setName("hasDataById")
367                 .setKind(org.apache.thrift.RpcKind.SINGLE_REQUEST_SINGLE_RESPONSE)
368                 .setOtherMetadata(getHeaders(rpcOptions))
369                 .setProtocol(_protocolId)
370                 .build();
371 
372             com.facebook.thrift.payload.ClientRequestPayload<Boolean> _crp =
373                 com.facebook.thrift.payload.ClientRequestPayload.create(
374                     _createhasDataByIdWriter(id),
375                     _hasDataById_READER,
376                     _hasDataById_EXCEPTION_READERS,
377                     _metadata,
378                     java.util.Collections.emptyMap());
379 
380             return _rpc
381                 .singleRequestSingleResponse(_crp, rpcOptions).doOnNext(_p -> {if(_p.getException() != null) throw reactor.core.Exceptions.propagate(_p.getException());});
382       });
383   }
384 
385   @java.lang.Override
386   public reactor.core.publisher.Mono<Boolean> hasDataById(final long id,  final com.facebook.thrift.client.RpcOptions rpcOptions) {
387     return hasDataByIdWrapper(id,  rpcOptions).map(_p -> _p.getData());
388   }
389 
390   @java.lang.Override
391   public reactor.core.publisher.Mono<Boolean> hasDataById(final long id) {
392     return hasDataById(id,  com.facebook.thrift.client.RpcOptions.EMPTY);
393   }
394 
395   private com.facebook.thrift.payload.Writer _creategetDataByIdWriter(final long id) {
396     return oprot -> {
397       try {
398         {
399           oprot.writeFieldBegin(_getDataById_ID_FIELD_DESC);
400 
401           long _iter0 = id;
402 
403           oprot.writeI64(id);
404           oprot.writeFieldEnd();
405         }
406 
407 
408       } catch (Throwable _e) {
409         throw reactor.core.Exceptions.propagate(_e);
410       }
411     };
412   }
413 
414   private static final com.facebook.thrift.payload.Reader _getDataById_READER =
415     oprot -> {
416               try {
417                 String _r = oprot.readString();
418                 return _r;
419 
420 
421               } catch (Throwable _e) {
422                 throw reactor.core.Exceptions.propagate(_e);
423               }
424             };
425 
426 
427   @java.lang.Override
428   public reactor.core.publisher.Mono<com.facebook.thrift.client.ResponseWrapper<String>> getDataByIdWrapper(final long id,  final com.facebook.thrift.client.RpcOptions rpcOptions) {
429     return _rpcClient
430       .flatMap(_rpc -> {
431         org.apache.thrift.RequestRpcMetadata _metadata = new org.apache.thrift.RequestRpcMetadata.Builder()
432                 .setName("getDataById")
433                 .setKind(org.apache.thrift.RpcKind.SINGLE_REQUEST_SINGLE_RESPONSE)
434                 .setOtherMetadata(getHeaders(rpcOptions))
435                 .setProtocol(_protocolId)
436                 .build();
437 
438             com.facebook.thrift.payload.ClientRequestPayload<String> _crp =
439                 com.facebook.thrift.payload.ClientRequestPayload.create(
440                     _creategetDataByIdWriter(id),
441                     _getDataById_READER,
442                     _getDataById_EXCEPTION_READERS,
443                     _metadata,
444                     java.util.Collections.emptyMap());
445 
446             return _rpc
447                 .singleRequestSingleResponse(_crp, rpcOptions).doOnNext(_p -> {if(_p.getException() != null) throw reactor.core.Exceptions.propagate(_p.getException());});
448       });
449   }
450 
451   @java.lang.Override
452   public reactor.core.publisher.Mono<String> getDataById(final long id,  final com.facebook.thrift.client.RpcOptions rpcOptions) {
453     return getDataByIdWrapper(id,  rpcOptions).map(_p -> _p.getData());
454   }
455 
456   @java.lang.Override
457   public reactor.core.publisher.Mono<String> getDataById(final long id) {
458     return getDataById(id,  com.facebook.thrift.client.RpcOptions.EMPTY);
459   }
460 
461   private com.facebook.thrift.payload.Writer _createdeleteDataByIdWriter(final long id) {
462     return oprot -> {
463       try {
464         {
465           oprot.writeFieldBegin(_deleteDataById_ID_FIELD_DESC);
466 
467           long _iter0 = id;
468 
469           oprot.writeI64(id);
470           oprot.writeFieldEnd();
471         }
472 
473 
474       } catch (Throwable _e) {
475         throw reactor.core.Exceptions.propagate(_e);
476       }
477     };
478   }
479 
480   private static final com.facebook.thrift.payload.Reader _deleteDataById_READER =
481     oprot -> {
482               try {
483 
484                 return null;
485 
486               } catch (Throwable _e) {
487                 throw reactor.core.Exceptions.propagate(_e);
488               }
489             };
490 
491 
492   @java.lang.Override
493   public reactor.core.publisher.Mono<com.facebook.thrift.client.ResponseWrapper<Void>> deleteDataByIdWrapper(final long id,  final com.facebook.thrift.client.RpcOptions rpcOptions) {
494     return _rpcClient
495       .flatMap(_rpc -> {
496         org.apache.thrift.RequestRpcMetadata _metadata = new org.apache.thrift.RequestRpcMetadata.Builder()
497                 .setName("deleteDataById")
498                 .setKind(org.apache.thrift.RpcKind.SINGLE_REQUEST_SINGLE_RESPONSE)
499                 .setOtherMetadata(getHeaders(rpcOptions))
500                 .setProtocol(_protocolId)
501                 .build();
502 
503             com.facebook.thrift.payload.ClientRequestPayload<Void> _crp =
504                 com.facebook.thrift.payload.ClientRequestPayload.create(
505                     _createdeleteDataByIdWriter(id),
506                     _deleteDataById_READER,
507                     _deleteDataById_EXCEPTION_READERS,
508                     _metadata,
509                     java.util.Collections.emptyMap());
510 
511             return _rpc
512                 .singleRequestSingleResponse(_crp, rpcOptions).doOnNext(_p -> {if(_p.getException() != null) throw reactor.core.Exceptions.propagate(_p.getException());});
513       });
514   }
515 
516   @java.lang.Override
517   public reactor.core.publisher.Mono<Void> deleteDataById(final long id,  final com.facebook.thrift.client.RpcOptions rpcOptions) {
518     return deleteDataByIdWrapper(id,  rpcOptions).then();
519   }
520 
521   @java.lang.Override
522   public reactor.core.publisher.Mono<Void> deleteDataById(final long id) {
523     return deleteDataById(id,  com.facebook.thrift.client.RpcOptions.EMPTY);
524   }
525 
526   private com.facebook.thrift.payload.Writer _createlobDataByIdWriter(final long id, final String data) {
527     return oprot -> {
528       try {
529         {
530           oprot.writeFieldBegin(_lobDataById_ID_FIELD_DESC);
531 
532           long _iter0 = id;
533 
534           oprot.writeI64(id);
535           oprot.writeFieldEnd();
536         }
537 
538         {
539           oprot.writeFieldBegin(_lobDataById_DATA_FIELD_DESC);
540 
541           String _iter0 = data;
542 
543           oprot.writeString(data);
544           oprot.writeFieldEnd();
545         }
546 
547 
548       } catch (Throwable _e) {
549         throw reactor.core.Exceptions.propagate(_e);
550       }
551     };
552   }
553 
554   private static final com.facebook.thrift.payload.Reader _lobDataById_READER =
555     oprot -> {
556               try {
557 
558                 return null;
559 
560               } catch (Throwable _e) {
561                 throw reactor.core.Exceptions.propagate(_e);
562               }
563             };
564 
565 
566   @java.lang.Override
567   public reactor.core.publisher.Mono<com.facebook.thrift.client.ResponseWrapper<Void>> lobDataByIdWrapper(final long id, final String data,  final com.facebook.thrift.client.RpcOptions rpcOptions) {
568     return _rpcClient
569       .flatMap(_rpc -> {
570         org.apache.thrift.RequestRpcMetadata _metadata = new org.apache.thrift.RequestRpcMetadata.Builder()
571                 .setName("lobDataById")
572                 .setKind(org.apache.thrift.RpcKind.SINGLE_REQUEST_NO_RESPONSE)
573                 .setOtherMetadata(getHeaders(rpcOptions))
574                 .setProtocol(_protocolId)
575                 .build();
576 
577             com.facebook.thrift.payload.ClientRequestPayload<Void> _crp =
578                 com.facebook.thrift.payload.ClientRequestPayload.create(
579                     _createlobDataByIdWriter(id, data),
580                     _lobDataById_READER,
581                     _lobDataById_EXCEPTION_READERS,
582                     _metadata,
583                     java.util.Collections.emptyMap());
584 
585             return _rpc
586                 .singleRequestNoResponse(_crp, rpcOptions).thenReturn(ResponseWrapper.create(null, java.util.Collections.emptyMap(), java.util.Collections.emptyMap()));
587       });
588   }
589 
590   @java.lang.Override
591   public reactor.core.publisher.Mono<Void> lobDataById(final long id, final String data,  final com.facebook.thrift.client.RpcOptions rpcOptions) {
592     return lobDataByIdWrapper(id, data,  rpcOptions).then();
593   }
594 
595   @java.lang.Override
596   public reactor.core.publisher.Mono<Void> lobDataById(final long id, final String data) {
597     return lobDataById(id, data,  com.facebook.thrift.client.RpcOptions.EMPTY);
598   }
599 
600 
601 
602   private Map<String, String> getHeaders(com.facebook.thrift.client.RpcOptions rpcOptions) {
603       Map<String, String> headers = new HashMap<>();
604       if (rpcOptions.getRequestHeaders() != null && !rpcOptions.getRequestHeaders().isEmpty()) {
605           headers.putAll(rpcOptions.getRequestHeaders());
606       }
607       if (_headers != null && !_headers.isEmpty()) {
608           headers.putAll(_headers);
609       }
610       if (_persistentHeaders != null && !_persistentHeaders.isEmpty()) {
611           headers.putAll(_persistentHeaders);
612       }
613       return headers;
614   }
615 }
616