Revert unnecessary changes

ballerina-platform · May 26, 2023 · 76ecdba · 76ecdba
1 parent 98161d4
commit 76ecdba
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 3 deletions.
diff --git a/ballerina/stream_types.bal b/ballerina/stream_types.bal
@@ -47,7 +47,6 @@ public class PersistInMemoryStream {
             return <persist:Error>self.err;
         } else if self.anydataStream is stream<record {}, error?> {
             var anydataStream = <stream<record {}, error?>>self.anydataStream;
-            checkpanic anydataStream.close();
             var streamValue = anydataStream.next();
             if streamValue is () {
                 return streamValue;
@@ -77,7 +76,7 @@ public class PersistInMemoryStream {
 
     public isolated function close() returns persist:Error? {
         if self.anydataStream is stream<anydata, error?> {
-            error? e = (<stream>self.anydataStream).close();
+            error? e = (<stream<anydata, error?>>self.anydataStream).close();
             if e is error {
                 return <persist:Error>error(e.message());
             }

diff --git a/ballerina/tests/in-memory-associations-tests.bal b/ballerina/tests/in-memory-associations-tests.bal
@@ -248,7 +248,6 @@ function inMemoryBuildingRelationsTest() returns error? {
     InMemoryRainierClient rainierClient = check new ();
 
     stream<BuildingInfo, error?> buildingStream = rainierClient->/buildings.get();
-    check buildingStream.close();
     BuildingInfo[] buildings = check from BuildingInfo building in buildingStream
         select building;