File tree Expand file tree Collapse file tree 2 files changed +6
-2
lines changed
Expand file tree Collapse file tree 2 files changed +6
-2
lines changed Original file line number Diff line number Diff line change @@ -94,14 +94,16 @@ export class grpcProgramAccountSubscriber<
9494 // Subscribe with grpc
9595 this . stream =
9696 ( await this . client . subscribe ( ) ) as unknown as typeof this . stream ;
97+
9798 const filters = this . options . filters . map ( ( filter ) => {
9899 return {
99100 memcmp : {
100101 offset : filter . memcmp . offset . toString ( ) ,
101- bytes : bs58 . decode ( filter . memcmp . bytes ) ,
102+ base58 : filter . memcmp . bytes ,
102103 } ,
103104 } ;
104105 } ) ;
106+
105107 const request : SubscribeRequest = {
106108 slots : { } ,
107109 accounts : {
Original file line number Diff line number Diff line change @@ -121,5 +121,7 @@ export async function createClient(
121121 ...args : ConstructorParameters < typeof Client >
122122) : Promise < Client > {
123123 const { default : Client_ } = await import ( '@triton-one/yellowstone-grpc' ) ;
124- return new Client_ ( ...args ) ;
124+ const client = new Client_ ( ...args ) ;
125+ await client . connect ( ) ;
126+ return client ;
125127}
You can’t perform that action at this time.
0 commit comments