diff --git a/packages/tendermint-rpc/package.json b/packages/tendermint-rpc/package.json index 794dc1d2..a4bc2ba6 100644 --- a/packages/tendermint-rpc/package.json +++ b/packages/tendermint-rpc/package.json @@ -49,6 +49,7 @@ "@cosmjs/json-rpc": "^0.20.0", "@cosmjs/math": "^0.20.0", "@cosmjs/socket": "^0.20.0", + "@cosmjs/stream": "^0.20.0", "axios": "^0.19.0", "readonly-date": "^1.0.0", "type-tagger": "^1.0.0", diff --git a/packages/tendermint-rpc/src/client.spec.ts b/packages/tendermint-rpc/src/client.spec.ts index 2e7e4557..8c32389a 100644 --- a/packages/tendermint-rpc/src/client.spec.ts +++ b/packages/tendermint-rpc/src/client.spec.ts @@ -1,6 +1,6 @@ import { toAscii } from "@cosmjs/encoding"; +import { firstEvent, toListPromise } from "@cosmjs/stream"; import { sleep } from "@cosmjs/utils"; -import { firstEvent, toListPromise } from "@iov/stream"; import { ReadonlyDate } from "readonly-date"; import { Stream } from "xstream"; diff --git a/packages/tendermint-rpc/src/rpcclients/websocketclient.spec.ts b/packages/tendermint-rpc/src/rpcclients/websocketclient.spec.ts index 9008e2c6..0f15cb79 100644 --- a/packages/tendermint-rpc/src/rpcclients/websocketclient.spec.ts +++ b/packages/tendermint-rpc/src/rpcclients/websocketclient.spec.ts @@ -1,4 +1,4 @@ -import { toListPromise } from "@iov/stream"; +import { toListPromise } from "@cosmjs/stream"; import { Stream } from "xstream"; import { defaultInstance } from "../config.spec"; diff --git a/packages/tendermint-rpc/src/rpcclients/websocketclient.ts b/packages/tendermint-rpc/src/rpcclients/websocketclient.ts index f6909cfd..458353fa 100644 --- a/packages/tendermint-rpc/src/rpcclients/websocketclient.ts +++ b/packages/tendermint-rpc/src/rpcclients/websocketclient.ts @@ -7,7 +7,7 @@ import { parseJsonRpcResponse, } from "@cosmjs/json-rpc"; import { ConnectionStatus, ReconnectingSocket, SocketWrapperMessageEvent } from "@cosmjs/socket"; -import { firstEvent } from "@iov/stream"; +import { firstEvent } from "@cosmjs/stream"; import { Listener, Producer, Stream, Subscription } from "xstream"; import { hasProtocol, RpcStreamingClient, SubscriptionEvent } from "./rpcclient";