e2e_test/lib/async_worker.dart

// Copyright (c) 2017, the Dart project authors.  Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.

import 'dart:async';
import 'dart:isolate';

import 'package:bazel_worker/bazel_worker.dart';

/// Example worker that just returns in its response all the arguments passed
/// separated by newlines.
class ExampleAsyncWorker extends AsyncWorkerLoop {
  /// Set [sendPort] to run in an isolate.
  ExampleAsyncWorker([SendPort sendPort])
      : super(connection: AsyncWorkerConnection(sendPort: sendPort));

  @override
  Future<WorkResponse> performRequest(WorkRequest request) async {
    return WorkResponse()
      ..exitCode = 0
      ..output = request.arguments.join('\n');
  }
}