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