diff --git a/dcli/lib/src/process/environment.dart b/dcli/lib/src/process/environment.dart index 5bcdfaf4..c2e82661 100644 --- a/dcli/lib/src/process/environment.dart +++ b/dcli/lib/src/process/environment.dart @@ -5,7 +5,8 @@ import 'package:dcli_core/dcli_core.dart'; /// Used internally to pass environment variables across an isolate /// boundary when using [ProcessSync] to synchronously call a process. class ProcessEnvironment { - factory ProcessEnvironment() => ProcessEnvironment._(envs, Env().caseSensitive); + factory ProcessEnvironment() => + ProcessEnvironment._(envs, Env().caseSensitive); ProcessEnvironment._(this.envVars, this.caseSensitive); diff --git a/dcli/lib/src/process/process/native_calls.dart b/dcli/lib/src/process/process/native_calls.dart index 421774f7..ea456e82 100644 --- a/dcli/lib/src/process/process/native_calls.dart +++ b/dcli/lib/src/process/process/native_calls.dart @@ -26,12 +26,16 @@ class NativeCalls { /// Don't really know why but we go and find the /// native dart method to connect to a port. static Object Function(int) _initNativeConnectToPort() { - final functions = NativeApi.initializeApiDLData.cast<_DartApi>().ref.functions; + final functions = + NativeApi.initializeApiDLData.cast<_DartApi>().ref.functions; late Object Function(int) connectToPort; for (var i = 0; functions[i].name != nullptr; i++) { if (functions[i].name.toDartString() == 'Dart_NewSendPort') { - connectToPort = functions[i].function.cast>().asFunction(); + connectToPort = functions[i] + .function + .cast>() + .asFunction(); break; } } diff --git a/dcli/lib/src/process/process/pipe_sync.dart b/dcli/lib/src/process/process/pipe_sync.dart index 6f02bf77..bcb142b1 100644 --- a/dcli/lib/src/process/process/pipe_sync.dart +++ b/dcli/lib/src/process/process/pipe_sync.dart @@ -30,7 +30,8 @@ class PipeSync { /// exit code do we return? int? get exitCode => _rhsChannel.exitCode; - /// Run the two given process as defined by [lhsSettings] (left-hand-side settings) and [rhsSettings] (right-hand-side settings). + /// Run the two given process as defined by [lhsSettings] + /// (left-hand-side settings) and [rhsSettings] (right-hand-side settings). /// piping the input from the [lhsSettings] process into the [rhsSettings] /// process. /// diff --git a/dcli/lib/src/util/runnable_process.dart b/dcli/lib/src/util/runnable_process.dart index 0ec2dbed..c243db8c 100644 --- a/dcli/lib/src/util/runnable_process.dart +++ b/dcli/lib/src/util/runnable_process.dart @@ -426,7 +426,8 @@ class RunnableProcess { // (Object e) { // // forget broken pipe after rhs terminates before lhs // }, - // test: (e) => e is SocketException && e.osError!.message == 'Broken pipe', + // test: (e) => e is SocketException + // && e.osError!.message == 'Broken pipe', // ); // } @@ -538,8 +539,10 @@ class RunnableProcess { void _waitForStreams() { // Wait for both streams to complete // ignore: discarded_futures - // TODO: restore - how do we ensure the output from streams has been processed. - // waitForEx(Future.wait([_stdoutCompleter.future, _stderrCompleter.future])); + // TODO: restore - how do we ensure the output + // from streams has been processed. + // waitForEx(Future.wait([_stdoutCompleter.future, + // _stderrCompleter.future])); } final _stdoutCompleter = Completer();