sashapolo commented on code in PR #1626:
URL: https://github.com/apache/ignite-3/pull/1626#discussion_r1097376120
##########
modules/metastorage-api/src/main/java/org/apache/ignite/internal/metastorage/MetaStorageManager.java:
##########
@@ -63,32 +63,40 @@ public interface MetaStorageManager extends IgniteComponent
{
* {@code revUpperBound == -1}.
*
* @param keyPrefix Prefix of the key to retrieve the entries. Couldn't be
{@code null}.
- * @return Cursor built upon entries corresponding to the given range and
revision.
+ * @return Publisher that will provide entries corresponding to the given
prefix.
* @throws OperationTimeoutException If the operation is timed out.
* @throws CompactedException If the desired revisions are removed from
the storage due to a compaction.
* @see ByteArray
* @see Entry
*/
- Cursor<Entry> prefix(ByteArray keyPrefix) throws NodeStoppingException;
+ Publisher<Entry> prefix(ByteArray keyPrefix);
Review Comment:
Because this is an async API. All other async methods (that return
`CompletableFuture`), do not throw these exceptions
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
