}

        @ParameterizedTest
        @DisplayName("Should read various remaining values")
        @ValueSource(ints = { 0, 1, 100, 1024, 65536, Integer.MAX_VALUE })
        void testReadVariousRemainingValues(int remaining) throws SMBProtocolDecodingException {
            byte[] buffer = createValidWriteResponse(0, remaining);

            int bytesRead = response.readBytesWireFormat(buffer, 0);

            assertEquals("Hello", new String(buffer, 0, bytesRead, "UTF-8"));

            // Read remaining bytes
            byte[] remaining = new byte[20];
            int remainingBytes = stream.read(remaining);
            assertEquals(8, remainingBytes); // ", World!"
            assertEquals(", World!", new String(remaining, 0, remainingBytes, "UTF-8"));
        }
    }

            // sge.setLength(data.remaining());
            // sge.setLkey(disniRegion.getLocalKey());
            // sgeList.add(sge);
            //
            // sendWR.setSg_list(sgeList);
            // endpoint.postSend(Arrays.asList(sendWR)).execute().free();

            log.debug("DiSNI RDMA send completed, {} bytes", data.remaining());

        } catch (Exception e) {

      return result;
    }
    int remaining = totalLen - result.length;
    result = Arrays.copyOf(result, totalLen);
    while (remaining > 0) {
      byte[] buf = bufs.remove();
      int bytesToCopy = min(remaining, buf.length);
      int resultOffset = totalLen - remaining;
      System.arraycopy(buf, 0, result, resultOffset, bytesToCopy);
      remaining -= bytesToCopy;
    }
    return result;
  }

      int remaining;
      @Nullable E element;

      @Override
      public boolean hasNext() {
        return (remaining > 0) || entryIterator.hasNext();
      }

      @Override
      public E next() {
        if (remaining <= 0) {
          Entry<E> entry = entryIterator.next();
          element = entry.getElement();
          remaining = entry.getCount();
        }

func deleteObjectVersions(ctx context.Context, o ObjectLayer, bucket string, toDel []ObjectToDelete, lcEvent []lifecycle.Event) {
	for remaining := toDel; len(remaining) > 0; toDel = remaining {
		if len(toDel) > maxDeleteList {
			remaining = toDel[maxDeleteList:]
			toDel = toDel[:maxDeleteList]
		} else {
			remaining = nil
		}
		vc, _ := globalBucketVersioningSys.Get(bucket)

        // Skip 3 bytes
        assertEquals(3, sis.skip(3));

        // Read remaining 2 bytes
        byte[] remaining = new byte[2];
        assertEquals(2, sis.read(remaining, 0, 2));
        assertArrayEquals(new byte[] { 40, 50 }, remaining);
    }

    @Test
    @DisplayName("Skip handles amount larger than available")

                        byte[] buffer = inv.getArgument(0);
                        int remaining = includeContent.length - index[0];
                        if (remaining <= 0) {
                            return -1;
                        }
                        int toRead = Math.min(buffer.length, remaining);
                        System.arraycopy(includeContent, index[0], buffer, 0, toRead);

            if (context.getServer() == null) {
                pos = 1;
            }

            // first remaining path element would be share
            if (nameParts.length > pos) {
                this.share = nameParts[pos];
                pos++;
            }

            // all other remaining path elements are actual path
            if (nameParts.length > pos) {

   *     {@link ByteOrder#LITTLE_ENDIAN}, to which a BYTES-long byte representation of this instance
   *     is written. In the process increases the position of {@link ByteBuffer} by BYTES.
   */
  void writeTo(ByteBuffer buffer) {
    checkNotNull(buffer);
    checkArgument(
        buffer.remaining() >= BYTES,