buf := make([]byte, 512)

	for b.Loop() {
		rb.Write(data)
		rb.Read(buf)
	}
}

func BenchmarkRingBuffer_AsyncRead(b *testing.B) {
	// Pretty useless benchmark, but it's here for completeness.
	rb := New(1024)
	data := []byte(strings.Repeat("a", 512))
	buf := make([]byte, 512)

	go func() {
		for {
			rb.Read(buf)
		}
	}()

	for b.Loop() {
		rb.Write(data)
	}
}

+-----+

 The <<<plexus.core>>> realm contains the resources required to run any
 plexus application; The <<<plexus.core.maven>>> realm contains all of the
 resources required to run Maven. Each subsequent plugin realm contains the
 JAR plugin as well as its dependencies. The realms noted above are setup
 in a hierarchical structure where the resources in the parent realms are
 available but the <<realm is searched first before a search is made in

  public void testOpenStream() throws IOException {
    Reader reader = source.openStream();

    StringWriter writer = new StringWriter();
    char[] buf = new char[64];
    int read;
    while ((read = reader.read(buf)) != -1) {
      writer.write(buf, 0, read);
    }
    reader.close();
    writer.close();

    assertExpectedString(writer.toString());
  }

  public void testOpenBufferedStream() throws IOException {

      @Throws(IOException::class)
      override fun read(
        sink: Buffer,
        byteCount: Long,
      ): Long {
        val buffer = Buffer()
        val read = delegate.read(buffer, byteCount)
        if (read != -1L) {
          sink.write(buffer.readByteString().toAsciiUppercase())
        }
        return read
      }
    }
  }

            else -> source.read(sink, limit)
          }
        }
      }

      override fun timeout(): Timeout = timeout
    }

    /**
     * Returns a value in [0..maxByteCount] with the number of bytes that can be read from [source]
     * in the current part. If this returns 0 the current part is exhausted; otherwise it has at
     * least one byte left to read.
     */

            SMBUtil.writeInt2(17, buffer, 0); // Structure size
            SMBUtil.writeInt2(0, buffer, 2); // Reserved
            SMBUtil.writeInt4(-1, buffer, 4); // Count (will be read as unsigned)
            SMBUtil.writeInt4(-2, buffer, 8); // Remaining (will be read as unsigned)
            SMBUtil.writeInt4(0, buffer, 12); // WriteChannelInfoOffset/Length

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

        // Flags should not be set for partial read
        assertFalse(d.getParametersDone(), "parametersDone should be false for partial read");
        assertFalse(d.getDataDone(), "dataDone should be false for partial read");
        assertTrue(d.getHasMore(), "hasMore should remain true for partial read");
    }

    /**
     * Test scenario with no data to read
     */
    @Test

    /**
     * CacheRecord
     */
    class CacheRecord {

        private final ClassRealm realm;

        private final ExtensionDescriptor descriptor;

        private final List<Artifact> artifacts;

        CacheRecord(ClassRealm realm, ExtensionDescriptor descriptor, List<Artifact> artifacts) {
            this.realm = realm;
            this.descriptor = descriptor;
            this.artifacts = artifacts;
        }

func jsonToValue(result any) (*Value, error) {
	switch rval := result.(type) {
	case string:
		return FromString(rval), nil
	case float64:
		return FromFloat(rval), nil
	case int64:
		return FromInt(rval), nil
	case uint64:
		if rval <= math.MaxInt64 {
			return FromInt(int64(rval)), nil
		}
		return FromFloat(float64(rval)), nil
	case bool:
		return FromBool(rval), nil
	case jstream.KVS:

			return n - remain, b.readErr()
		}
	}
}

// Read reads data into p.
// It returns the number of bytes read into p.
// The bytes are taken from at most one Read on the underlying [Reader],
// hence n may be less than len(p).
// To read exactly len(p) bytes, use io.ReadFull(b, p).
// If the underlying [Reader] can return a non-zero count with io.EOF,
// then this Read method can do so as well; see the [io.Reader] docs.