Method Watch

internal/storage/memory/watch.go:24–35

Watch - Watches for changes in the repository.

(_ context.Context, _, _ string)

// Watch - Watches for changes in the repository.
func (r *Watch) Watch(_ context.Context, _, _ string) (<-chan *base.DataChanges, <-chan error) {
	tupleChanges := make(chan *base.DataChanges)
	errs := make(chan error)

	slog.Info(base.ErrorCode_ERROR_CODE_NOT_IMPLEMENTED.String())

	// Close the channels immediately
	close(tupleChanges)
	close(errs)

	return tupleChanges, errs
}