Added fibers in log fiters to enable futures

mobile/android/logcat-helper.ts

@@ -1,5 +1,6 @@
 import byline = require("byline");
 import {DeviceAndroidDebugBridge} from "./device-android-debug-bridge";
+import * as fiberBootstrap from "../../fiber-bootstrap";
 
 export class LogcatHelper implements Mobile.ILogcatHelper {
 	private mapDeviceToLoggingStarted: IDictionary<boolean>;
@@ -40,7 +41,9 @@ export class LogcatHelper implements Mobile.ILogcatHelper {
 
 			lineStream.on('data', (line: NodeBuffer) => {
 				let lineText = line.toString();
-				this.$deviceLogProvider.logData(lineText, this.$devicePlatformsConstants.Android, deviceIdentifier);
+				fiberBootstrap.run(() =>
+					this.$deviceLogProvider.logData(lineText, this.$devicePlatformsConstants.Android, deviceIdentifier)
+				);
 			});
 
 			this.$processService.attachToProcessExitSignals(this, adbLogcat.kill);

mobile/ios/device/ios-core.ts

@@ -14,6 +14,7 @@ import * as string_decoder from "string_decoder";
 import * as stream from "stream";
 import * as assert from "assert";
 import {EOL} from "os";
+import * as fiberBootstrap from "../../../fiber-bootstrap";
 
 export class CoreTypes {
 	public static pointerSize = ref.types.size_t.size;
@@ -1117,7 +1118,9 @@ class GDBStandardOutputAdapter extends stream.Transform {
 			}
 
 			if (this.$deviceLogProvider) {
-				this.$deviceLogProvider.logData(result, this.$devicePlatformsConstants.iOS, this.deviceIdentifier);
+				fiberBootstrap.run(() =>
+					this.$deviceLogProvider.logData(result, this.$devicePlatformsConstants.iOS, this.deviceIdentifier)
+				);
 			}
 
 			done(null, result);

mobile/ios/device/ios-proxy-services.ts

@@ -4,6 +4,7 @@ import * as iOSCore from "./ios-core";
 import * as helpers from "../../../helpers";
 import * as plistlib from "plistlib";
 import Future = require("fibers/future");
+import * as fiberBootstrap from "../../../fiber-bootstrap";
 
 export class MobileServices {
 	public static APPLE_FILE_CONNECTION: string = "com.apple.afc";
@@ -497,7 +498,9 @@ export class IOSSyslog {
 
 	public read(): void {
 		let printData = (data: string) => {
-			this.$deviceLogProvider.logData(data, this.$devicePlatformsConstants.iOS, this.device.deviceInfo.identifier);
+			fiberBootstrap.run(() =>
+				this.$deviceLogProvider.logData(data, this.$devicePlatformsConstants.iOS, this.device.deviceInfo.identifier)
+			);
 		};
 		this.plistService.readSystemLog(printData);
 	}

mobile/ios/simulator/ios-simulator-log-provider.ts

@@ -1,4 +1,5 @@
 import { ChildProcess } from "child_process";
+import * as fiberBootstrap from "../../../fiber-bootstrap";
 
 export class IOSSimulatorLogProvider implements Mobile.IiOSSimulatorLogProvider {
 	private isStarted: boolean;
@@ -12,7 +13,11 @@ export class IOSSimulatorLogProvider implements Mobile.IiOSSimulatorLogProvider
 		if (!this.isStarted) {
 			let deviceLogChildProcess: ChildProcess = this.$iOSSimResolver.iOSSim.getDeviceLogProcess(deviceIdentifier);
 
-			let action = (data: NodeBuffer | string) => this.$deviceLogProvider.logData(data.toString(), this.$devicePlatformsConstants.iOS, deviceIdentifier);
+			let action = (data: NodeBuffer | string) => {
+				fiberBootstrap.run(() =>
+					this.$deviceLogProvider.logData(data.toString(), this.$devicePlatformsConstants.iOS, deviceIdentifier)
+				);
+			};
 
 			if (deviceLogChildProcess.stdout) {
 				deviceLogChildProcess.stdout.on("data", action);