*Bug fix
This commit is contained in:
parent
05c9a7aea7
commit
35c67e1c92
|
@ -117,7 +117,7 @@ export function createHash(data: string): Buffer {
|
||||||
|
|
||||||
export async function setupStream(stream: any) {
|
export async function setupStream(stream: any) {
|
||||||
const existing = stream[RPC_PROTOCOL_SYMBOL];
|
const existing = stream[RPC_PROTOCOL_SYMBOL];
|
||||||
if (!existing) {
|
if (existing) {
|
||||||
await existing._channel.ready;
|
await existing._channel.ready;
|
||||||
return existing;
|
return existing;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue