parse correctly

Author: davidmurdoch

packages/core/lib/console-child.js

@@ -3,7 +3,7 @@ const TruffleError = require("@truffle/error");
 const Config = require("@truffle/config");
 const Web3 = require("web3");
 const yargs = require("yargs");
-const StreamingWeb3HttpProvider = require("@truffle/stream-provider");
+const StreamingWeb3HttpProvider = require("@truffle/stream-provider").default;
 
 const crypto = require("crypto");
 global.crypto = crypto;

packages/core/lib/package.js

@@ -7,7 +7,7 @@ const { createInterfaceAdapter } = require("@truffle/interface-adapter");
 const path = require("path");
 const fs = require("fs");
 const OS = require("os");
-const StreamingWeb3HttpProvider = require("@truffle/stream-provider");
+const StreamingWeb3HttpProvider = require("@truffle/stream-provider").default;
 
 const Package = {
   install: async function(options, callback) {

packages/environment/environment.js

@@ -6,7 +6,7 @@ const Resolver = require("@truffle/resolver");
 const Artifactor = require("@truffle/artifactor");
 const Ganache = require("ganache-core/public-exports");
 const Provider = require("@truffle/provider");
-const StreamingWeb3HttpProvider = require("@truffle/stream-provider");
+const StreamingWeb3HttpProvider = require("@truffle/stream-provider").default;
 
 const Environment = {
   // It's important config is a Config object and not a vanilla object

packages/provider/index.js

@@ -3,7 +3,7 @@ const Web3 = require("web3");
 const { createInterfaceAdapter } = require("@truffle/interface-adapter");
 const wrapper = require("./wrapper");
 const DEFAULT_NETWORK_CHECK_TIMEOUT = 5000;
-const StreamingWeb3HttpProvider = require("@truffle/stream-provider");
+const StreamingWeb3HttpProvider = require("@truffle/stream-provider").default;
 
 module.exports = {
   wrap: function (provider, options) {

packages/stream-provider/lib/index.ts

@@ -61,7 +61,7 @@ export default class StreamingWeb3HttpProvider extends Web3HttpProvider {
           let error = null;
           let result: any = {};
           const stream = response.data.pipe(
-            JSONStream.parse([true, { emitKey: true }])
+            JSONStream.parse([{ emitKey: true }])
           );
           try {
             result = await new Promise((resolve, reject) => {

packages/stream-provider/test/stream.ts

@@ -42,7 +42,7 @@ describe("test", () => {
   });
   (it("handle giant traces", async () => {
     const provider = new StreamingWeb3HttpProvider(`http://localhost:${PORT}`);
-    const result = await new Promise<any>((resolve, reject) => {
+    const { result } = await new Promise<any>((resolve, reject) => {
       provider.send(
         {
           id: 1,