.subscribe() is not async.
This commit is contained in:
parent
8840c4d8e2
commit
71b412657f
|
@ -71,7 +71,7 @@ test('listening and publishing and closing', async () => {
|
|||
}),
|
||||
])
|
||||
|
||||
let sub = await relay.subscribe(
|
||||
let sub = relay.subscribe(
|
||||
[
|
||||
{
|
||||
kinds: [23571],
|
||||
|
|
2
relay.ts
2
relay.ts
|
@ -247,7 +247,7 @@ export class Relay {
|
|||
return ret
|
||||
}
|
||||
|
||||
public async subscribe(filters: Filter[], params: Partial<SubscriptionParams>): Promise<Subscription> {
|
||||
public subscribe(filters: Filter[], params: Partial<SubscriptionParams>): Subscription {
|
||||
const subscription = this.prepareSubscription(filters, params)
|
||||
subscription.fire()
|
||||
return subscription
|
||||
|
|
Loading…
Reference in New Issue