mirror of
https://github.com/XRPLF/rippled.git
synced 2025-11-24 21:15:58 +00:00
Allow RPC subscribe with no streams.
This commit is contained in:
@@ -2346,12 +2346,6 @@ Json::Value RPCHandler::doSubscribe(Json::Value jvRequest)
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (jvRequest.isMember("streams"))
|
if (jvRequest.isMember("streams"))
|
||||||
{
|
|
||||||
if (jvRequest["streams"].empty())
|
|
||||||
{
|
|
||||||
jvResult["error"] = "noStreams";
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
{
|
||||||
for (Json::Value::iterator it = jvRequest["streams"].begin(); it != jvRequest["streams"].end(); it++)
|
for (Json::Value::iterator it = jvRequest["streams"].begin(); it != jvRequest["streams"].end(); it++)
|
||||||
{
|
{
|
||||||
@@ -2380,7 +2374,7 @@ Json::Value RPCHandler::doSubscribe(Json::Value jvRequest)
|
|||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
jvResult["error"] = str(boost::format("Unknown stream: %s") % streamName);
|
jvResult["error"] = "unknownStream";
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
@@ -2389,7 +2383,6 @@ Json::Value RPCHandler::doSubscribe(Json::Value jvRequest)
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
if (jvRequest.isMember("rt_accounts"))
|
if (jvRequest.isMember("rt_accounts"))
|
||||||
{
|
{
|
||||||
|
|||||||
Reference in New Issue
Block a user