abstract class MyCopyTask extends DefaultTask {

    @InputDirectory abstract DirectoryProperty getSource()

    @OutputDirectory abstract DirectoryProperty getDestination()

    @Inject abstract FileSystemOperations getFs()

    @TaskAction
    void action() {
        fs.copy {
            from source
            into destination
        }
    }
}

// tag::fixed-reuse[]
tasks.register('someTask', MyCopyTask) {

    public abstract DirectoryProperty getDestinationDirectory();

    @Inject
    protected abstract FileSystemOperations getFs();

    @TaskAction
    public void generate() {
        // TODO: This could probably use InputChanges API
        File destinationDirectory = getDestinationDirectory().get().getAsFile();
        getFs().delete(spec -> spec.delete(destinationDirectory));
        destinationDirectory.mkdirs();

							const args = loadSliceOfValues(sp + 32);
							const result = Reflect.apply(m, v, args);
							sp = this._inst.exports.getsp() >>> 0; // see comment above
							storeValue(sp + 56, result);
							this.mem.setUint8(sp + 64, 1);
						} catch (err) {
							sp = this._inst.exports.getsp() >>> 0; // see comment above
							storeValue(sp + 56, err);
							this.mem.setUint8(sp + 64, 0);
						}
					},

    @InputDirectory abstract DirectoryProperty getSource() // <2>

    @OutputDirectory abstract DirectoryProperty getDestination() // <2>

    @Inject abstract FileSystemOperations getFs() // <3>

    @TaskAction
    void action() {
        fs.copy { // <3>
            from source
            into destination
        }
    }
}

tasks.register('someTask', MyCopyTask) {

    @Input
    public abstract MapProperty<String, String> getReplacementTokens();

    @Inject
    protected abstract FileSystemOperations getFs();

    @TaskAction
    public void transform() {
        File destinationFile = getDestinationFile().get().getAsFile();

        getFs().copy(copySpec -> {
            copySpec.from(getHtmlFile());
            copySpec.into(destinationFile.getParentFile());

		}
	}))
	c.handler = func(e krt.Event[Workload]) {
		events <- fmt.Sprintf(e.Latest().Name, e.Event)
	}
	go c.queue.Run(stop)
}

var nextIP = net.ParseIP("10.0.0.10")

func GetIP() string {
	i := nextIP.To4()
	ret := i.String()
	v := uint(i[0])<<24 + uint(i[1])<<16 + uint(i[2])<<8 + uint(i[3])
	v++
	v3 := byte(v & 0xFF)
	v2 := byte((v >> 8) & 0xFF)
	v1 := byte((v >> 16) & 0xFF)

		}
		return true, nil
	}
	if err := wait.PollImmediate(10*time.Millisecond, time.Second, getFn); err != nil {
		t.Errorf("unexpected error: %v", err)
	}

	// Eventually we should observer secret deletion.
	fakeWatch.Delete(secret)
	getFn = func() (bool, error) {
		_, err := store.Get("ns", "name")
		if err != nil {
			if apierrors.IsNotFound(err) {
				return true, nil

                @InputFile abstract RegularFileProperty getArchiveFile()
                @OutputDirectory abstract DirectoryProperty getUnpackDir()
                @Inject abstract FileSystemOperations getFs()
                @Inject abstract ArchiveOperations getArchives()
                @TaskAction void action() {
                    fs.copy {
                        from(archives.${archiveType}Tree(archiveFile))

        given:
        def nonAsciiFileName = "القيادة والسيطرة - الإدارة.lnk"

        buildFile """
            interface Services {
                @Inject FileSystemOperations getFs()
            }
            task copyFiles {
                def fs = objects.newInstance(Services).fs
                doLast {
                    fs.copy {
                        from 'res'

        op.getLoc(), op.getType(), batchInputOp.getInputDataset(),
        batchInputOp.getOtherArguments(), op.getBatchSize(),
        num_parallel_calls_op.getY(), op.getDropRemainder(),
        batchInputOp.getF(), op.getOutputTypes(), op.getOutputShapes(),
        batchInputOp.getPreserveCardinality(), op.getMetadata());
    rewriter.replaceOp(op, {fused_op.getHandle()});
    return failure();
  }
};