MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-09-27 10:03:11 +07:00
Code Issues Packages Projects Releases Wiki Activity

CPP-16921 Allow specifying BaseOutputReader options for RemoteProcessHandler

Browse Source 
GitOrigin-RevId: 0e780630f04d1035859fcd5fef9bb8728ca46f67
This commit is contained in:
Semyon Kolton
2019-12-24 10:05:47 +00:00
committed by intellij-monorepo-bot
parent 04d353efbb
commit bc5e69a390
1 changed files with 17 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/platform-impl/src/com/intellij/remote/BaseRemoteProcessHandler.java
+17 -4
View File
@@ -40,6 +40,15 @@ public class BaseRemoteProcessHandler<T extends RemoteProcess> extends BaseProce
super(process, commandLine, charset);
}
/**
* Override this method to fine-tune {@link BaseOutputReader} behavior.
*/
@NotNull
protected BaseOutputReader.Options readerOptions() {
return new BaseOutputReader.Options();
}
@Override
protected void destroyProcessImpl() {
if (!myProcess.killProcessTree()) {
@@ -55,7 +64,7 @@ public class BaseRemoteProcessHandler<T extends RemoteProcess> extends BaseProce
@Override
public void startNotified(@NotNull final ProcessEvent event) {
try {
final RemoteOutputReader stdoutReader = new RemoteOutputReader(myProcess.getInputStream(), getCharset(), myProcess, myCommandLine) {
final RemoteOutputReader stdoutReader = new RemoteOutputReader(myProcess.getInputStream(), getCharset(), myProcess, myCommandLine, readerOptions()) {
@Override
protected void onTextAvailable(@NotNull String text) {
notifyTextAvailable(text, ProcessOutputTypes.STDOUT);
@@ -68,7 +77,7 @@ public class BaseRemoteProcessHandler<T extends RemoteProcess> extends BaseProce
}
};
final RemoteOutputReader stderrReader = new RemoteOutputReader(myProcess.getErrorStream(), getCharset(), myProcess, myCommandLine) {
final RemoteOutputReader stderrReader = new RemoteOutputReader(myProcess.getErrorStream(), getCharset(), myProcess, myCommandLine, readerOptions()) {
@Override
protected void onTextAvailable(@NotNull String text) {
notifyTextAvailable(text, ProcessOutputTypes.STDERR);
@@ -113,8 +122,12 @@ public class BaseRemoteProcessHandler<T extends RemoteProcess> extends BaseProce
@NotNull private final RemoteProcess myRemoteProcess;
private boolean myClosed;
RemoteOutputReader(@NotNull InputStream inputStream, Charset charset, @NotNull RemoteProcess remoteProcess, @NotNull String commandLine) {
super(inputStream, charset);
RemoteOutputReader(@NotNull InputStream inputStream,
Charset charset,
@NotNull RemoteProcess remoteProcess,
@NotNull String commandLine,
@NotNull Options options) {
super(inputStream, charset, options);
myRemoteProcess = remoteProcess;