@@ -16,3 +18,3 @@
 //
 // If remote RPC does not support neo-go session API, fallback to List() method.
-func (c *Client) ContainersOf(idUser *user.ID) ([]cid.ID, error) {
+func (c *Client) ContainersOf(prm *container.ContainersOfClientPrm) ([]cid.ID, error) {

@@ -25,2 +42,3 @@
+
 	var cidList []cid.ID
-	cb := func(item stackitem.Item) error {
+	appendCIDtoList := func(item stackitem.Item) error {

@@ -5,6 +5,8 @@ import (
 	"fmt"
 
 	"git.frostfs.info/TrueCloudLab/frostfs-node/pkg/morph/client"
+	container "git.frostfs.info/TrueCloudLab/frostfs-node/pkg/services/container/morph"

@@ -63,0 +105,4 @@
+		return err
+	}
+
+	if !batchProcessed {

@@ -223,0 +226,4 @@
+	}
+	return s.rdr.ContainersOfWithProcessing(&id, processCIDList)
+}
+

@@ -30,6 +30,7 @@ type Reader interface {
 	// to the specified user of FrostFS system. Returns the identifiers
 	// of all FrostFS containers if pointer to owner identifier is nil.
 	ContainersOf(*user.ID) ([]cid.ID, error)
+	ContainersOfWithProcessing(*user.ID, func([]cid.ID) error) error

@@ -220,0 +228,4 @@
+		default:
+		}
+		cidList = append(cidList, id)
+		if len(cidList) == 512 { // 512 is batch size from pkg/morph/client/container/containers_of.go

@@ -63,0 +105,4 @@
+// This method uses `(*Client).TestInvokeIterator()` which can return
+// `unwrap.ErrNoSessionID` if the remote neo-go node does not support sessions.
+// So providing handler for this type of errors is required.
+func (c *Client) iterateContainers(idUser *user.ID, cb func(item stackitem.Item) error, handleSessionError func() error) error {

@@ -220,0 +223,4 @@
+	var cidList []cid.ID
+	processCID := func(id cid.ID) error {
+		select {
+		case <-stream.Context().Done():

@@ -202,3 +203,3 @@
 }
 
-func (s *morphExecutor) ListStream(_ context.Context, req *container.ListStreamRequest, stream containerSvc.ListStream) error {
+func (s *morphExecutor) ListStream(ctx context.Context, req *container.ListStreamRequest, stream containerSvc.ListStream) error {

@@ -58,0 +55,4 @@
+func getCIDfromStackItem(item stackitem.Item) (cid.ID, error) {
+	rawID, err := client.BytesFromStackItem(item)
+	if err != nil {
+		return [32]byte{}, fmt.Errorf("get byte array from stack item (%s): %w", listMethod, err)

@@ -220,0 +231,4 @@
+		if len(cidList) == 512 { // 512 is batch size from pkg/morph/client/container/containers_of.go
+			r.GetBody().SetContainerIDs(getRefCIDList(cidList))
+			cidList = make([]cid.ID, 0, 512)
+			return stream.Send(r)

@@ -220,0 +228,4 @@
+		default:
+		}
+		cidList = append(cidList, id)
+		if len(cidList) == 512 { // 512 is batch size from pkg/morph/client/container/containers_of.go

@@ -220,0 +230,4 @@
+		cidList = append(cidList, id)
+		if len(cidList) == 512 { // 512 is batch size from pkg/morph/client/container/containers_of.go
+			r.GetBody().SetContainerIDs(getRefCIDList(cidList))
+			cidList = make([]cid.ID, 0, 512)

@@ -25,3 +39,1 @@
-	var cidList []cid.ID
-	cb := func(item stackitem.Item) error {
-		rawID, err := client.BytesFromStackItem(item)
+	cnrHash := c.client.ContractAddress()