1818
1919'use strict' ;
2020
21- var assert = require ( 'assert' ) ;
21+ var assert = require ( 'power- assert' ) ;
2222var extend = require ( 'extend' ) ;
2323var File = require ( '../../lib/storage/file' ) ;
2424var mockery = require ( 'mockery' ) ;
25- var Stream = require ( 'stream' ) ;
26- var through = require ( 'through2' ) ;
25+ var stream = require ( 'stream' ) ;
2726var util = require ( '../../lib/common/util' ) ;
2827
2928function FakeFile ( a , b ) {
@@ -35,7 +34,6 @@ var fakeUtil = extend({}, util, {
3534 makeWritableStream : function ( ) {
3635 var args = [ ] . slice . call ( arguments ) ;
3736 ( makeWritableStream_Override || util . makeWritableStream ) . apply ( null , args ) ;
38- makeWritableStream_Override = null ;
3937 }
4038} ) ;
4139
@@ -81,6 +79,7 @@ describe('BigQuery/Table', function() {
8179 } ) ;
8280
8381 beforeEach ( function ( ) {
82+ makeWritableStream_Override = null ;
8483 table = new Table ( DATASET , TABLE_ID ) ;
8584 } ) ;
8685
@@ -221,7 +220,7 @@ describe('BigQuery/Table', function() {
221220
222221 describe ( 'createReadStream' , function ( ) {
223222 it ( 'should return a stream' , function ( ) {
224- assert ( table . createReadStream ( ) instanceof Stream ) ;
223+ assert ( table . createReadStream ( ) instanceof stream . Stream ) ;
225224 } ) ;
226225
227226 it ( 'should call getRows() when asked for data' , function ( done ) {
@@ -339,7 +338,7 @@ describe('BigQuery/Table', function() {
339338 } ) ;
340339
341340 it ( 'should return a stream' , function ( ) {
342- assert ( table . createWriteStream ( ) instanceof Stream ) ;
341+ assert ( table . createWriteStream ( ) instanceof stream . Stream ) ;
343342 } ) ;
344343
345344 describe ( 'writable stream' , function ( ) {
@@ -699,7 +698,7 @@ describe('BigQuery/Table', function() {
699698
700699 it ( 'should accept just a File and a callback' , function ( done ) {
701700 table . createWriteStream = function ( ) {
702- var ws = new Stream . Writable ( ) ;
701+ var ws = new stream . Writable ( ) ;
703702 setImmediate ( function ( ) {
704703 ws . emit ( 'complete' ) ;
705704 ws . end ( ) ;
@@ -712,16 +711,16 @@ describe('BigQuery/Table', function() {
712711
713712 it ( 'should return a stream when a string is given' , function ( ) {
714713 table . createWriteStream = function ( ) {
715- return new Stream . Writable ( ) ;
714+ return new stream . Writable ( ) ;
716715 } ;
717716
718- assert ( table . import ( FILEPATH ) instanceof Stream ) ;
717+ assert ( table . import ( FILEPATH ) instanceof stream . Stream ) ;
719718 } ) ;
720719
721720 it ( 'should infer the file format from the given filepath' , function ( done ) {
722721 table . createWriteStream = function ( metadata ) {
723722 assert . equal ( metadata . sourceFormat , 'NEWLINE_DELIMITED_JSON' ) ;
724- var ws = new Stream . Writable ( ) ;
723+ var ws = new stream . Writable ( ) ;
725724 setImmediate ( function ( ) {
726725 ws . emit ( 'complete' ) ;
727726 ws . end ( ) ;
@@ -735,7 +734,7 @@ describe('BigQuery/Table', function() {
735734 it ( 'should not infer the file format if one is given' , function ( done ) {
736735 table . createWriteStream = function ( metadata ) {
737736 assert . equal ( metadata . sourceFormat , 'CSV' ) ;
738- var ws = new Stream . Writable ( ) ;
737+ var ws = new stream . Writable ( ) ;
739738 setImmediate ( function ( ) {
740739 ws . emit ( 'complete' ) ;
741740 ws . end ( ) ;
0 commit comments