src/RSocketResponder.cpp
/// Handles a new inbound RequestResponse requested by the other end.
Handles a new inbound RequestResponse requested by the other end.
Handles a new inbound RequestResponse requested by the other end .
void RSocketResponder::handleRequestResponseCore(
    Payload request,
    StreamId streamId,
    const yarpl::Reference<yarpl::single::SingleObserver<Payload>>&
    responseObserver) noexcept {
  auto single = handleRequestResponse(std::move(request), streamId);
  single->subscribe(std::move(responseObserver));
}
void RSocketResponder :: handleRequestResponseCore ( Payload request , StreamId streamId , const yarpl :: Reference < yarpl :: single :: SingleObserver < Payload > > & responseObserver ) noexcept { auto single = handleRequestResponse ( std :: move ( request ) , streamId ) ; single -> subscribe ( std :: move ( responseObserver ) ) ; }
Handles a new inbound RequestResponse requested by the other end.
Handles a new inbound RequestResponse requested by the other end .