diff --git a/packages/schematics/src/sink/dryrun.ts b/packages/schematics/src/sink/dryrun.ts
index c6fd64cd30..184cbf4907 100644
--- a/packages/schematics/src/sink/dryrun.ts
+++ b/packages/schematics/src/sink/dryrun.ts
@@ -7,9 +7,9 @@
  */
 import {FileSystemSink} from './filesystem';
 
-import {Observable} from 'rxjs';
-import {Subject} from 'rxjs';
-
+import {Observable} from 'rxjs/Observable';
+import {Subject} from 'rxjs/Subject';
+import 'rxjs/add/observable/empty';
 
 
 export interface DryRunErrorEvent {
diff --git a/packages/schematics/src/sink/sink.ts b/packages/schematics/src/sink/sink.ts
index 48937c4db5..81f02c968e 100644
--- a/packages/schematics/src/sink/sink.ts
+++ b/packages/schematics/src/sink/sink.ts
@@ -24,6 +24,7 @@ import 'rxjs/add/operator/concatMap';
 import 'rxjs/add/operator/ignoreElements';
 import 'rxjs/add/operator/last';
 import 'rxjs/add/operator/mergeMap';
+import 'rxjs/add/observable/from';
 
 
 export interface Sink {
diff --git a/packages/schematics/src/sink/virtual-filesystem.ts b/packages/schematics/src/sink/virtual-filesystem.ts
index ef51a7cc2c..72b2d36df5 100644
--- a/packages/schematics/src/sink/virtual-filesystem.ts
+++ b/packages/schematics/src/sink/virtual-filesystem.ts
@@ -12,7 +12,9 @@ import {UpdateBuffer} from '../utility/update-buffer';
 
 import {Observable} from 'rxjs/Observable';
 import 'rxjs/add/observable/merge';
+import 'rxjs/add/observable/concat';
 import 'rxjs/add/operator/reduce';
+import 'rxjs/add/operator/do';
 
 
 export interface VirtualFileSystemSinkHost {