Apply suggestions from code review

README.md

@@ -21,8 +21,6 @@ To use the MongoDB connector, you need to have a MongoDB server running and acce
 
 ### Setup a MongoDB server locally
 
-#### Step 1: Install and run the MongoDB server
-
 1. Download and install the MongoDB server from the [MongoDB download center](https://www.mongodb.com/try/download/community).
 
 2. Follow the installation instructions provided in the download center.

ballerina/Dependencies.toml

@@ -5,7 +5,7 @@
 
 [ballerina]
 dependencies-toml-version = "2"
-distribution-version = "2201.8.5"
+distribution-version = "2201.8.6"
 
 [[package]]
 org = "ballerina"

ballerina/Module.md

@@ -12,8 +12,6 @@ To use the MongoDB connector, you need to have a MongoDB server running and acce
 
 ### Setup a MongoDB server locally
 
-#### Step 1: Install and run the MongoDB server
-
 1. Download and install the MongoDB server from the [MongoDB download center](https://www.mongodb.com/try/download/community).
 
 2. Follow the installation instructions provided in the download center.

ballerina/Package.md

@@ -12,8 +12,6 @@ To use the MongoDB connector, you need to have a MongoDB server running and acce
 
 ### Setup a MongoDB server locally
 
-#### Step 1: Install and run the MongoDB server
-
 1. Download and install the MongoDB server from the [MongoDB download center](https://www.mongodb.com/try/download/community).
 
 2. Follow the installation instructions provided in the download center.

ballerina/client.bal

@@ -61,6 +61,8 @@ public isolated client class Client {
 
     # Closes the client.
     #
+    # > **Note:** Use a single client instance for the lifetime of the application and close it when the application is done.
+    #
     # + return - A `mongodb:Error` if the client is already closed or failed to close the client. `()` otherwise.
     @display {label: "Close the Client"}
     remote isolated function close() returns Error? = @java:Method {

ballerina/collection.bal

@@ -58,14 +58,16 @@
 
     # Finds documents from the collection.
     #
+    # > **Note:** Close the resulted stream once the operation is completed.
+    #
     # + filter - The query filter to apply when retrieving documents
     # + findOptions - The additional options to apply to the find operation
     # + projection - The projection to apply to the find operation. If not provided, the projection will be generated
     # based on the targetType
     # + targetType - The type of the returned documents
     # + return - A stream of documents which match the provided filter, or an error if the operation failed
     isolated remote function find(map<json> filter = {}, FindOptions findOptions = {}, map<json>? projection = (),
-    typedesc<anydata> targetType = <>) returns stream<targetType, error?>|Error = @java:Method {
+    typedesc<record {|anydata...;|}> targetType = <>) returns stream<targetType, error?>|Error = @java:Method {
         'class: "io.ballerina.lib.mongodb.Collection"
     } external;
 
@@ -78,7 +80,7 @@
     # + targetType - The type of the returned document
     # + return - The document which matches the provided filter, or an error if the operation failed
     isolated remote function findOne(map<json> filter = {}, FindOptions findOptions = {}, map<json>? projection = (),
-    typedesc<anydata> targetType = <>) returns targetType|Error = @java:Method {
+    typedesc<record {|anydata...;|}> targetType = <>) returns targetType|Error? = @java:Method {
         'class: "io.ballerina.lib.mongodb.Collection"
     } external;
 
@@ -104,6 +106,8 @@
 
     # Lists the indexes of the collection.
     #
+    # > **Note:** Close the resulted stream once the operation is completed.
+    #
     # + return - A stream of indexes, or an error if the operation failed
     isolated remote function listIndexes() returns stream<Index, error?>|Error =
     @java:Method {
@@ -156,6 +160,8 @@
 
     # Retrieves the distinct values for a specified field across a collection.
     #
+    # > **Note:** Close the resulted stream once the operation is completed.
+    #
     # + fieldName - The field for which to return distinct values
     # + filter - The query filter to apply when retrieving distinct values
     # + targetType - The type of the returned distinct values
@@ -185,6 +191,8 @@
 
     # Aggregates documents according to the specified aggregation pipeline.
     #
+    # > **Note:** Close the resulted stream once the operation is completed.
+    #
     # + pipeline - The aggregation pipeline
     # + targetType - The type of the returned documents
     # + return - A stream of documents which match the provided pipeline, or an error if the operation failed

ballerina/tests/03_collection_tests.bal

@@ -52,9 +52,11 @@ isolated function testInsertAndFind() returns error? {
 isolated function testFindOne() returns error? {
     Database database = check mongoClient->getDatabase("testFindOneDB");
     Collection collection = check database->getCollection("Movies");
+    Movie? actualResult = check collection->findOne();
+    test:assertEquals(actualResult, (), "Expected an empty result");
     Movie movie = {name: "Interstellar", year: 2014, rating: 9};
     check collection->insertOne(movie);
-    Movie? actualResult = check collection->findOne();
+    actualResult = check collection->findOne();
     test:assertEquals(actualResult, movie);
     check collection->drop();
     check database->drop();