stream, err := conn.NewStream(ctx, grid.HandlerDiskInfo, payload)
	if err != nil {
        return err
    }
    // Read results from the stream
    err = stream.Results(func(result []byte) error {
        fmt.Println("Got result", string(result))

        // Return the response for reuse
        grid.PutByteBuffer(result)
        return nil
    })
```

Context cancellation and timeouts are propagated to the handler.

        // TCP doesn't need real memory registration
        return new TcpMemoryRegion(buffer, access);
    }

    @Override
    public String getProviderName() {
        return "TCP Fallback";
    }

    @Override
    public int getMaxMessageSize() {
        return 65536; // 64KB for TCP
    }

    @Override
    public void shutdown() {

  }

  @Override public ServerSocket createServerSocket() throws IOException {
    return new UnixDomainServerSocket();
  }

  @Override public ServerSocket createServerSocket(int port) throws IOException {
    return createServerSocket();
  }

  @Override public ServerSocket createServerSocket(int port, int backlog) throws IOException {
    return createServerSocket();
  }

  @Override public ServerSocket createServerSocket(

      int j = i & ARRAY_MASK;
      tmp += UnsignedLongs.divide(longs[j], divisors[j]);
    }
    return tmp;
  }

  @Benchmark
  long remainder(int reps) {
    long tmp = 0;
    for (int i = 0; i < reps; i++) {
      int j = i & ARRAY_MASK;
      tmp += UnsignedLongs.remainder(longs[j], divisors[j]);
    }
    return tmp;
  }

  @Benchmark
  long parseUnsignedLong(int reps) {
    long tmp = 0;

     * @param mimeType The MIME type of the content.
     * @return The file extension including the dot (e.g., ".gif"), or empty string if unknown.
     */
    protected String getExtensionFromMimeType(final String mimeType) {
        if (mimeType == null) {
            return "";
        }
        return switch (mimeType) {
        case "image/gif" -> ".gif";
        case "image/tiff" -> ".tiff";

            afterSessionStart(session);
        } catch (MavenExecutionException e) {
            return addExceptionToResult(result, e);
        }

        try {
            chainedWorkspaceReader.addReader(lookup.lookup(WorkspaceReader.class, ReactorReader.HINT));
        } catch (LookupException e) {
            return addExceptionToResult(result, e);
        }

        }
        return (T) component;
    }

    /**
     * Wraps an object instance into a pooled object.
     *
     * @param obj The object to wrap
     * @return A PooledObject wrapping the given object
     */
    @Override
    public PooledObject<T> wrap(final T obj) {
        return new DefaultPooledObject<>(obj);
    }

    /**

    public String getScope() {
        return parent.getScope();
    }

    @Override
    public void setScope(String scope) {
        throw new UnsupportedOperationException("Cannot change the scoping information for an attached artifact."
                + " It is derived from the main artifact.");
    }

    @Override
    public String getVersion() {
        return parent.getVersion();
    }

			if errors.Is(err, errConfigNotFound) {
				return newServerCfg()
			}
			return nil, err
		}

		data, err = decryptData(data, configFile)
		if err != nil {
			return nil, err
		}

		newCfg, err := readServerConfig(GlobalContext, objAPI, data)
		if err == nil {
			return newCfg, nil
		}

		// Read older `.minio.sys/config/config.json`, if not

    /**
     * Gets the number of bytes actually read
     *
     * @return the dataLength
     */
    public int getDataLength() {
        return this.dataLength;
    }

    /**
     * Gets the number of bytes remaining to be read
     *
     * @return the dataRemaining
     */
    public int getDataRemaining() {
        return this.dataRemaining;
    }

    /**
     * {@inheritDoc}
     *