parse correctly

Author: davidmurdoch

packages/environment/environment.js

@@ -5,7 +5,7 @@ const { Resolver } = require("@truffle/resolver");
 const Artifactor = require("@truffle/artifactor");
 const Ganache = require("ganache");
 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,