Payload /*request*/,

StreamId /*streamId*/,

const std::shared_ptr<Subscriber<Payload>>& response) noexcept {

// TODO(lehecka): get rid of onSubscribe call

response->onSubscribe(std::make_shared<NullSubscription>());

response->onError(std::runtime_error("NullRequestHandler"));

return std::make_shared<NullSubscriber>();

Payload /*request*/,

StreamId /*streamId*/,

const std::shared_ptr<Subscriber<Payload>>& response) noexcept {

// TODO(lehecka): get rid of onSubscribe call

response->onSubscribe(std::make_shared<NullSubscription>());

response->onError(std::runtime_error("NullRequestHandler"));

Payload /*request*/,

StreamId /*streamId*/,

const std::shared_ptr<Subscriber<Payload>>& response) noexcept {

// TODO(lehecka): get rid of onSubscribe call

response->onSubscribe(std::make_shared<NullSubscription>());

response->onError(std::runtime_error("NullRequestHandler"));

Payload /*request*/,

StreamId /*streamId*/,

const std::shared_ptr<Subscriber<Payload>>& response) noexcept {

response->onSubscribe(std::make_shared<NullSubscription>());

response->onError(std::runtime_error("NullRequestHandler"));

ReactiveSocket& socket,

ConnectionSetupPayload /*request*/) noexcept {

return nullptr;

ReactiveSocket& socket,

const ResumeIdentificationToken& /*token*/,

ResumePosition /*position*/) noexcept {

return false;