Fix offline packaging using event stream

gulpfile.js

@@ -20,11 +20,15 @@ const util = require('./out/src/common');
 const child_process = require('child_process');
 const optionsSchemaGenerator = require('./out/src/tools/GenerateOptionsSchema');
 const packageDependencyUpdater = require('./out/src/tools/UpdatePackageDependencies');
+const eventStream = require('./out/src/EventStream');
+const csharpLoggerObserver = require('./out/src/observers/CsharpLoggerObserver');
 
+const EventStream = eventStream.EventStream;
 const Logger = logger.Logger;
 const PackageManager = packages.PackageManager;
 const LinuxDistribution = platform.LinuxDistribution;
 const PlatformInformation = platform.PlatformInformation;
+const CsharpLoggerObserver = csharpLoggerObserver.CsharpLoggerObserver;
 
 function cleanSync(deleteVsix) {
     del.sync('install.*');
@@ -51,12 +55,15 @@ gulp.task('updatePackageDependencies', () => {
 // Install Tasks
 function install(platformInfo, packageJSON) {
     const packageManager = new PackageManager(platformInfo, packageJSON);
+    let eventStream = new EventStream();
     const logger = new Logger(message => process.stdout.write(message));
+    let stdoutObserver = new CsharpLoggerObserver(logger);
+    eventStream.subscribe(stdoutObserver.post);
     const debuggerUtil = new debugUtil.CoreClrDebugUtil(path.resolve('.'), logger);
 
-    return packageManager.DownloadPackages(logger)
+    return packageManager.DownloadPackages(eventStream)
         .then(() => {
-            return packageManager.InstallPackages(logger);
+            return packageManager.InstallPackages(eventStream);
         })
         .then(() => {
             return util.touchInstallFile(util.InstallFileType.Lock)

src/observers/BaseLoggerObserver.ts

@@ -9,8 +9,13 @@ import { BaseEvent } from '../omnisharp/loggingEvents';
 
 export abstract class BaseLoggerObserver {
     public logger: Logger;
-    constructor(channel: vscode.OutputChannel) {
-        this.logger = new Logger((message) => channel.append(message));
+    constructor(channel: vscode.OutputChannel | Logger) {
+        if (channel instanceof Logger) {
+            this.logger = channel as Logger;
+        }
+        else {
+            this.logger = new Logger((message) => channel.append(message));
+        }    
     }
 
     abstract post: (event: BaseEvent) => void;