@solana/rpc-subscriptions
Advanced tools
Comparing version 2.0.0-experimental.e3e579c to 2.0.0-experimental.e587f8d
@@ -1,2 +0,2 @@ | ||
import { createSolanaRpcSubscriptionsApi, createSolanaRpcSubscriptionsApi_UNSTABLE } from '@solana/rpc-subscriptions-api'; | ||
import { createSolanaRpcSubscriptionsApi } from '@solana/rpc-subscriptions-api'; | ||
export * from '@solana/rpc-subscriptions-api'; | ||
@@ -7,3 +7,3 @@ import { createSubscriptionRpc } from '@solana/rpc-subscriptions-spec'; | ||
import fastStableStringify from 'fast-stable-stringify'; | ||
import { SolanaError, SOLANA_ERROR__RPC_INTEGER_OVERFLOW } from '@solana/errors'; | ||
import { SolanaError, SOLANA_ERROR__RPC__INTEGER_OVERFLOW, SOLANA_ERROR__INVARIANT_VIOLATION__CACHED_ABORTABLE_ITERABLE_CACHE_ENTRY_MISSING } from '@solana/errors'; | ||
import { createWebSocketTransport } from '@solana/rpc-subscriptions-transport-websocket'; | ||
@@ -32,3 +32,3 @@ | ||
const path = keyPath.length > 1 ? keyPath.slice(1).map((pathPart) => typeof pathPart === "number" ? `[${pathPart}]` : pathPart).join(".") : void 0; | ||
const error = new SolanaError(SOLANA_ERROR__RPC_INTEGER_OVERFLOW, { | ||
const error = new SolanaError(SOLANA_ERROR__RPC__INTEGER_OVERFLOW, { | ||
argumentLabel, | ||
@@ -54,4 +54,2 @@ keyPath, | ||
}; | ||
// src/cached-abortable-iterable.ts | ||
function registerIterableCleanup(iterable, cleanupFn) { | ||
@@ -70,3 +68,2 @@ (async () => { | ||
getAbortSignalFromInputArgs, | ||
getCacheEntryMissingError, | ||
getCacheKeyFromInputArgs, | ||
@@ -80,3 +77,5 @@ onCacheHit, | ||
if (!currentCacheEntry) { | ||
throw getCacheEntryMissingError(cacheKey); | ||
throw new SolanaError(SOLANA_ERROR__INVARIANT_VIOLATION__CACHED_ABORTABLE_ITERABLE_CACHE_ENTRY_MISSING, { | ||
cacheKey: cacheKey.toString() | ||
}); | ||
} | ||
@@ -182,7 +181,2 @@ return currentCacheEntry; | ||
getAbortSignalFromInputArgs: ({ abortSignal }) => abortSignal, | ||
getCacheEntryMissingError(deduplicationKey2) { | ||
return new Error( | ||
`Found no cache entry for subscription with deduplication key \`${deduplicationKey2?.toString()}\`` | ||
); | ||
}, | ||
getCacheKeyFromInputArgs: () => deduplicationKey, | ||
@@ -246,22 +240,2 @@ async onCacheHit(_iterable, _config) { | ||
// src/rpc-subscriptions.ts | ||
function createSolanaRpcSubscriptions(config) { | ||
return pipe( | ||
createSubscriptionRpc({ | ||
...config, | ||
api: createSolanaRpcSubscriptionsApi(DEFAULT_RPC_CONFIG) | ||
}), | ||
(rpcSubscriptions) => getRpcSubscriptionsWithSubscriptionCoalescing({ | ||
getDeduplicationKey: (...args) => fastStableStringify(args), | ||
rpcSubscriptions | ||
}) | ||
); | ||
} | ||
function createSolanaRpcSubscriptions_UNSTABLE(config) { | ||
return createSubscriptionRpc({ | ||
...config, | ||
api: createSolanaRpcSubscriptionsApi_UNSTABLE(DEFAULT_RPC_CONFIG) | ||
}); | ||
} | ||
// src/rpc-subscriptions-autopinger.ts | ||
@@ -343,5 +317,2 @@ var PING_PAYLOAD = { | ||
getAbortSignalFromInputArgs: ({ signal }) => signal, | ||
getCacheEntryMissingError(shardKey) { | ||
return new Error(`Found no cache entry for connection with shard key \`${shardKey?.toString()}\``); | ||
}, | ||
getCacheKeyFromInputArgs: ({ payload }) => getShard ? getShard(payload) : NULL_SHARD_CACHE_KEY, | ||
@@ -376,4 +347,31 @@ onCacheHit: (connection, { payload }) => connection.send_DO_NOT_USE_OR_YOU_WILL_BE_FIRED(payload), | ||
export { createDefaultRpcSubscriptionsTransport, createSolanaRpcSubscriptions, createSolanaRpcSubscriptions_UNSTABLE }; | ||
// src/rpc-subscriptions.ts | ||
function createSolanaRpcSubscriptions(clusterUrl, config) { | ||
const transport = createDefaultRpcSubscriptionsTransport({ url: clusterUrl, ...config }); | ||
return createSolanaRpcSubscriptionsFromTransport(transport); | ||
} | ||
function createSolanaRpcSubscriptions_UNSTABLE(clusterUrl, config) { | ||
return createSolanaRpcSubscriptions( | ||
clusterUrl, | ||
config | ||
); | ||
} | ||
function createSolanaRpcSubscriptionsFromTransport(transport) { | ||
return pipe( | ||
createSubscriptionRpc({ | ||
api: createSolanaRpcSubscriptionsApi(DEFAULT_RPC_CONFIG), | ||
transport | ||
}), | ||
(rpcSubscriptions) => getRpcSubscriptionsWithSubscriptionCoalescing({ | ||
getDeduplicationKey: (...args) => fastStableStringify(args), | ||
rpcSubscriptions | ||
}) | ||
); | ||
} | ||
function createSolanaRpcSubscriptionsFromTransport_UNSTABLE(transport) { | ||
return createSolanaRpcSubscriptionsFromTransport(transport); | ||
} | ||
export { createDefaultRpcSubscriptionsTransport, createSolanaRpcSubscriptions, createSolanaRpcSubscriptionsFromTransport, createSolanaRpcSubscriptionsFromTransport_UNSTABLE, createSolanaRpcSubscriptions_UNSTABLE }; | ||
//# sourceMappingURL=out.js.map | ||
//# sourceMappingURL=index.browser.js.map |
@@ -1,2 +0,2 @@ | ||
import { createSolanaRpcSubscriptionsApi, createSolanaRpcSubscriptionsApi_UNSTABLE } from '@solana/rpc-subscriptions-api'; | ||
import { createSolanaRpcSubscriptionsApi } from '@solana/rpc-subscriptions-api'; | ||
export * from '@solana/rpc-subscriptions-api'; | ||
@@ -7,3 +7,3 @@ import { createSubscriptionRpc } from '@solana/rpc-subscriptions-spec'; | ||
import fastStableStringify from 'fast-stable-stringify'; | ||
import { SolanaError, SOLANA_ERROR__RPC_INTEGER_OVERFLOW } from '@solana/errors'; | ||
import { SolanaError, SOLANA_ERROR__RPC__INTEGER_OVERFLOW, SOLANA_ERROR__INVARIANT_VIOLATION__CACHED_ABORTABLE_ITERABLE_CACHE_ENTRY_MISSING } from '@solana/errors'; | ||
import { createWebSocketTransport } from '@solana/rpc-subscriptions-transport-websocket'; | ||
@@ -32,3 +32,3 @@ | ||
const path = keyPath.length > 1 ? keyPath.slice(1).map((pathPart) => typeof pathPart === "number" ? `[${pathPart}]` : pathPart).join(".") : void 0; | ||
const error = new SolanaError(SOLANA_ERROR__RPC_INTEGER_OVERFLOW, { | ||
const error = new SolanaError(SOLANA_ERROR__RPC__INTEGER_OVERFLOW, { | ||
argumentLabel, | ||
@@ -54,4 +54,2 @@ keyPath, | ||
}; | ||
// src/cached-abortable-iterable.ts | ||
function registerIterableCleanup(iterable, cleanupFn) { | ||
@@ -70,3 +68,2 @@ (async () => { | ||
getAbortSignalFromInputArgs, | ||
getCacheEntryMissingError, | ||
getCacheKeyFromInputArgs, | ||
@@ -80,3 +77,5 @@ onCacheHit, | ||
if (!currentCacheEntry) { | ||
throw getCacheEntryMissingError(cacheKey); | ||
throw new SolanaError(SOLANA_ERROR__INVARIANT_VIOLATION__CACHED_ABORTABLE_ITERABLE_CACHE_ENTRY_MISSING, { | ||
cacheKey: cacheKey.toString() | ||
}); | ||
} | ||
@@ -182,7 +181,2 @@ return currentCacheEntry; | ||
getAbortSignalFromInputArgs: ({ abortSignal }) => abortSignal, | ||
getCacheEntryMissingError(deduplicationKey2) { | ||
return new Error( | ||
`Found no cache entry for subscription with deduplication key \`${deduplicationKey2?.toString()}\`` | ||
); | ||
}, | ||
getCacheKeyFromInputArgs: () => deduplicationKey, | ||
@@ -246,22 +240,2 @@ async onCacheHit(_iterable, _config) { | ||
// src/rpc-subscriptions.ts | ||
function createSolanaRpcSubscriptions(config) { | ||
return pipe( | ||
createSubscriptionRpc({ | ||
...config, | ||
api: createSolanaRpcSubscriptionsApi(DEFAULT_RPC_CONFIG) | ||
}), | ||
(rpcSubscriptions) => getRpcSubscriptionsWithSubscriptionCoalescing({ | ||
getDeduplicationKey: (...args) => fastStableStringify(args), | ||
rpcSubscriptions | ||
}) | ||
); | ||
} | ||
function createSolanaRpcSubscriptions_UNSTABLE(config) { | ||
return createSubscriptionRpc({ | ||
...config, | ||
api: createSolanaRpcSubscriptionsApi_UNSTABLE(DEFAULT_RPC_CONFIG) | ||
}); | ||
} | ||
// src/rpc-subscriptions-autopinger.ts | ||
@@ -332,5 +306,2 @@ var PING_PAYLOAD = { | ||
getAbortSignalFromInputArgs: ({ signal }) => signal, | ||
getCacheEntryMissingError(shardKey) { | ||
return new Error(`Found no cache entry for connection with shard key \`${shardKey?.toString()}\``); | ||
}, | ||
getCacheKeyFromInputArgs: ({ payload }) => getShard ? getShard(payload) : NULL_SHARD_CACHE_KEY, | ||
@@ -365,4 +336,31 @@ onCacheHit: (connection, { payload }) => connection.send_DO_NOT_USE_OR_YOU_WILL_BE_FIRED(payload), | ||
export { createDefaultRpcSubscriptionsTransport, createSolanaRpcSubscriptions, createSolanaRpcSubscriptions_UNSTABLE }; | ||
// src/rpc-subscriptions.ts | ||
function createSolanaRpcSubscriptions(clusterUrl, config) { | ||
const transport = createDefaultRpcSubscriptionsTransport({ url: clusterUrl, ...config }); | ||
return createSolanaRpcSubscriptionsFromTransport(transport); | ||
} | ||
function createSolanaRpcSubscriptions_UNSTABLE(clusterUrl, config) { | ||
return createSolanaRpcSubscriptions( | ||
clusterUrl, | ||
config | ||
); | ||
} | ||
function createSolanaRpcSubscriptionsFromTransport(transport) { | ||
return pipe( | ||
createSubscriptionRpc({ | ||
api: createSolanaRpcSubscriptionsApi(DEFAULT_RPC_CONFIG), | ||
transport | ||
}), | ||
(rpcSubscriptions) => getRpcSubscriptionsWithSubscriptionCoalescing({ | ||
getDeduplicationKey: (...args) => fastStableStringify(args), | ||
rpcSubscriptions | ||
}) | ||
); | ||
} | ||
function createSolanaRpcSubscriptionsFromTransport_UNSTABLE(transport) { | ||
return createSolanaRpcSubscriptionsFromTransport(transport); | ||
} | ||
export { createDefaultRpcSubscriptionsTransport, createSolanaRpcSubscriptions, createSolanaRpcSubscriptionsFromTransport, createSolanaRpcSubscriptionsFromTransport_UNSTABLE, createSolanaRpcSubscriptions_UNSTABLE }; | ||
//# sourceMappingURL=out.js.map | ||
//# sourceMappingURL=index.native.js.map |
@@ -1,2 +0,2 @@ | ||
import { createSolanaRpcSubscriptionsApi, createSolanaRpcSubscriptionsApi_UNSTABLE } from '@solana/rpc-subscriptions-api'; | ||
import { createSolanaRpcSubscriptionsApi } from '@solana/rpc-subscriptions-api'; | ||
export * from '@solana/rpc-subscriptions-api'; | ||
@@ -7,3 +7,3 @@ import { createSubscriptionRpc } from '@solana/rpc-subscriptions-spec'; | ||
import fastStableStringify from 'fast-stable-stringify'; | ||
import { SolanaError, SOLANA_ERROR__RPC_INTEGER_OVERFLOW } from '@solana/errors'; | ||
import { SolanaError, SOLANA_ERROR__RPC__INTEGER_OVERFLOW, SOLANA_ERROR__INVARIANT_VIOLATION__CACHED_ABORTABLE_ITERABLE_CACHE_ENTRY_MISSING } from '@solana/errors'; | ||
import { createWebSocketTransport } from '@solana/rpc-subscriptions-transport-websocket'; | ||
@@ -32,3 +32,3 @@ | ||
const path = keyPath.length > 1 ? keyPath.slice(1).map((pathPart) => typeof pathPart === "number" ? `[${pathPart}]` : pathPart).join(".") : void 0; | ||
const error = new SolanaError(SOLANA_ERROR__RPC_INTEGER_OVERFLOW, { | ||
const error = new SolanaError(SOLANA_ERROR__RPC__INTEGER_OVERFLOW, { | ||
argumentLabel, | ||
@@ -54,4 +54,2 @@ keyPath, | ||
}; | ||
// src/cached-abortable-iterable.ts | ||
function registerIterableCleanup(iterable, cleanupFn) { | ||
@@ -70,3 +68,2 @@ (async () => { | ||
getAbortSignalFromInputArgs, | ||
getCacheEntryMissingError, | ||
getCacheKeyFromInputArgs, | ||
@@ -80,3 +77,5 @@ onCacheHit, | ||
if (!currentCacheEntry) { | ||
throw getCacheEntryMissingError(cacheKey); | ||
throw new SolanaError(SOLANA_ERROR__INVARIANT_VIOLATION__CACHED_ABORTABLE_ITERABLE_CACHE_ENTRY_MISSING, { | ||
cacheKey: cacheKey.toString() | ||
}); | ||
} | ||
@@ -182,7 +181,2 @@ return currentCacheEntry; | ||
getAbortSignalFromInputArgs: ({ abortSignal }) => abortSignal, | ||
getCacheEntryMissingError(deduplicationKey2) { | ||
return new Error( | ||
`Found no cache entry for subscription with deduplication key \`${deduplicationKey2?.toString()}\`` | ||
); | ||
}, | ||
getCacheKeyFromInputArgs: () => deduplicationKey, | ||
@@ -246,22 +240,2 @@ async onCacheHit(_iterable, _config) { | ||
// src/rpc-subscriptions.ts | ||
function createSolanaRpcSubscriptions(config) { | ||
return pipe( | ||
createSubscriptionRpc({ | ||
...config, | ||
api: createSolanaRpcSubscriptionsApi(DEFAULT_RPC_CONFIG) | ||
}), | ||
(rpcSubscriptions) => getRpcSubscriptionsWithSubscriptionCoalescing({ | ||
getDeduplicationKey: (...args) => fastStableStringify(args), | ||
rpcSubscriptions | ||
}) | ||
); | ||
} | ||
function createSolanaRpcSubscriptions_UNSTABLE(config) { | ||
return createSubscriptionRpc({ | ||
...config, | ||
api: createSolanaRpcSubscriptionsApi_UNSTABLE(DEFAULT_RPC_CONFIG) | ||
}); | ||
} | ||
// src/rpc-subscriptions-autopinger.ts | ||
@@ -332,5 +306,2 @@ var PING_PAYLOAD = { | ||
getAbortSignalFromInputArgs: ({ signal }) => signal, | ||
getCacheEntryMissingError(shardKey) { | ||
return new Error(`Found no cache entry for connection with shard key \`${shardKey?.toString()}\``); | ||
}, | ||
getCacheKeyFromInputArgs: ({ payload }) => getShard ? getShard(payload) : NULL_SHARD_CACHE_KEY, | ||
@@ -365,4 +336,31 @@ onCacheHit: (connection, { payload }) => connection.send_DO_NOT_USE_OR_YOU_WILL_BE_FIRED(payload), | ||
export { createDefaultRpcSubscriptionsTransport, createSolanaRpcSubscriptions, createSolanaRpcSubscriptions_UNSTABLE }; | ||
// src/rpc-subscriptions.ts | ||
function createSolanaRpcSubscriptions(clusterUrl, config) { | ||
const transport = createDefaultRpcSubscriptionsTransport({ url: clusterUrl, ...config }); | ||
return createSolanaRpcSubscriptionsFromTransport(transport); | ||
} | ||
function createSolanaRpcSubscriptions_UNSTABLE(clusterUrl, config) { | ||
return createSolanaRpcSubscriptions( | ||
clusterUrl, | ||
config | ||
); | ||
} | ||
function createSolanaRpcSubscriptionsFromTransport(transport) { | ||
return pipe( | ||
createSubscriptionRpc({ | ||
api: createSolanaRpcSubscriptionsApi(DEFAULT_RPC_CONFIG), | ||
transport | ||
}), | ||
(rpcSubscriptions) => getRpcSubscriptionsWithSubscriptionCoalescing({ | ||
getDeduplicationKey: (...args) => fastStableStringify(args), | ||
rpcSubscriptions | ||
}) | ||
); | ||
} | ||
function createSolanaRpcSubscriptionsFromTransport_UNSTABLE(transport) { | ||
return createSolanaRpcSubscriptionsFromTransport(transport); | ||
} | ||
export { createDefaultRpcSubscriptionsTransport, createSolanaRpcSubscriptions, createSolanaRpcSubscriptionsFromTransport, createSolanaRpcSubscriptionsFromTransport_UNSTABLE, createSolanaRpcSubscriptions_UNSTABLE }; | ||
//# sourceMappingURL=out.js.map | ||
//# sourceMappingURL=index.node.js.map |
type CacheKey = string | symbol; | ||
type Config<TInput extends unknown[], TIterable extends AsyncIterable<unknown>> = Readonly<{ | ||
getAbortSignalFromInputArgs: (...args: TInput) => AbortSignal; | ||
getCacheEntryMissingError: (cacheKey: CacheKey) => Error; | ||
getCacheKeyFromInputArgs: (...args: TInput) => CacheKey | undefined; | ||
@@ -9,4 +8,4 @@ onCacheHit: (iterable: TIterable, ...args: TInput) => Promise<void>; | ||
}>; | ||
export declare function getCachedAbortableIterableFactory<TInput extends unknown[], TIterable extends AsyncIterable<unknown>>({ getAbortSignalFromInputArgs, getCacheEntryMissingError, getCacheKeyFromInputArgs, onCacheHit, onCreateIterable, }: Config<TInput, TIterable>): (...args: TInput) => Promise<TIterable>; | ||
export declare function getCachedAbortableIterableFactory<TInput extends unknown[], TIterable extends AsyncIterable<unknown>>({ getAbortSignalFromInputArgs, getCacheKeyFromInputArgs, onCacheHit, onCreateIterable, }: Config<TInput, TIterable>): (...args: TInput) => Promise<TIterable>; | ||
export {}; | ||
//# sourceMappingURL=cached-abortable-iterable.d.ts.map |
@@ -1,4 +0,4 @@ | ||
import { SOLANA_ERROR__RPC_INTEGER_OVERFLOW, SolanaError } from '@solana/errors'; | ||
import { SOLANA_ERROR__RPC__INTEGER_OVERFLOW, SolanaError } from '@solana/errors'; | ||
import type { KeyPath } from '@solana/rpc-transformers'; | ||
export declare function createSolanaJsonRpcIntegerOverflowError(methodName: string, keyPath: KeyPath, value: bigint): SolanaError<typeof SOLANA_ERROR__RPC_INTEGER_OVERFLOW>; | ||
export declare function createSolanaJsonRpcIntegerOverflowError(methodName: string, keyPath: KeyPath, value: bigint): SolanaError<typeof SOLANA_ERROR__RPC__INTEGER_OVERFLOW>; | ||
//# sourceMappingURL=rpc-integer-overflow-error.d.ts.map |
import type { ClusterUrl } from '@solana/rpc-types'; | ||
import { RpcSubscriptionsTransportFromClusterUrl } from './rpc-subscriptions-clusters.js'; | ||
type Config<TClusterUrl extends ClusterUrl> = Readonly<{ | ||
export type DefaultRpcSubscriptionsTransportConfig<TClusterUrl extends ClusterUrl> = Readonly<{ | ||
url: TClusterUrl; | ||
}>; | ||
export declare function createDefaultRpcSubscriptionsTransport<TClusterUrl extends ClusterUrl>(config: Config<TClusterUrl> & { | ||
/** | ||
@@ -15,4 +13,4 @@ * You might like to open more subscriptions per connection than your RPC provider allows | ||
sendBufferHighWatermark?: number; | ||
}): RpcSubscriptionsTransportFromClusterUrl<TClusterUrl>; | ||
export {}; | ||
}>; | ||
export declare function createDefaultRpcSubscriptionsTransport<TClusterUrl extends ClusterUrl>(config: DefaultRpcSubscriptionsTransportConfig<TClusterUrl>): RpcSubscriptionsTransportFromClusterUrl<TClusterUrl>; | ||
//# sourceMappingURL=rpc-subscriptions-transport.d.ts.map |
@@ -1,10 +0,10 @@ | ||
import type { SolanaRpcSubscriptionsApi, SolanaRpcSubscriptionsApiUnstable } from '@solana/rpc-subscriptions-api'; | ||
import { type RpcSubscriptionsTransport } from '@solana/rpc-subscriptions-spec'; | ||
import type { SolanaRpcSubscriptionsApi } from '@solana/rpc-subscriptions-api'; | ||
import { RpcSubscriptionsApiMethods, type RpcSubscriptionsTransport } from '@solana/rpc-subscriptions-spec'; | ||
import { ClusterUrl } from '@solana/rpc-types'; | ||
import type { RpcSubscriptionsFromTransport } from './rpc-subscriptions-clusters.js'; | ||
type RpcSubscriptionsConfig<TTransport extends RpcSubscriptionsTransport> = Readonly<{ | ||
transport: TTransport; | ||
}>; | ||
export declare function createSolanaRpcSubscriptions<TTransport extends RpcSubscriptionsTransport>(config: RpcSubscriptionsConfig<TTransport>): RpcSubscriptionsFromTransport<SolanaRpcSubscriptionsApi, TTransport>; | ||
export declare function createSolanaRpcSubscriptions_UNSTABLE<TTransport extends RpcSubscriptionsTransport>(config: RpcSubscriptionsConfig<TTransport>): RpcSubscriptionsFromTransport<SolanaRpcSubscriptionsApi & SolanaRpcSubscriptionsApiUnstable, TTransport>; | ||
export {}; | ||
import { DefaultRpcSubscriptionsTransportConfig } from './rpc-subscriptions-transport.js'; | ||
export declare function createSolanaRpcSubscriptions<TClusterUrl extends ClusterUrl, TApi extends RpcSubscriptionsApiMethods = SolanaRpcSubscriptionsApi>(clusterUrl: TClusterUrl, config?: Omit<DefaultRpcSubscriptionsTransportConfig<TClusterUrl>, 'url'>): RpcSubscriptionsFromTransport<TApi, import("./rpc-subscriptions-clusters").RpcSubscriptionsTransportFromClusterUrl<TClusterUrl>>; | ||
export declare function createSolanaRpcSubscriptions_UNSTABLE<TClusterUrl extends ClusterUrl>(clusterUrl: TClusterUrl, config?: Omit<DefaultRpcSubscriptionsTransportConfig<TClusterUrl>, 'url'>): RpcSubscriptionsFromTransport<import("@solana/rpc-subscriptions-api").AccountNotificationsApi & import("@solana/rpc-subscriptions-api").LogsNotificationsApi & import("@solana/rpc-subscriptions-api").ProgramNotificationsApi & import("@solana/rpc-subscriptions-api").RootNotificationsApi & import("@solana/rpc-subscriptions-api").SignatureNotificationsApi & import("@solana/rpc-subscriptions-api").SlotNotificationsApi & import("@solana/rpc-subscriptions-api").BlockNotificationsApi & import("@solana/rpc-subscriptions-api").SlotsUpdatesNotificationsApi & import("@solana/rpc-subscriptions-api").VoteNotificationsApi, import("./rpc-subscriptions-clusters").RpcSubscriptionsTransportFromClusterUrl<TClusterUrl>>; | ||
export declare function createSolanaRpcSubscriptionsFromTransport<TTransport extends RpcSubscriptionsTransport, TApi extends RpcSubscriptionsApiMethods = SolanaRpcSubscriptionsApi>(transport: TTransport): RpcSubscriptionsFromTransport<TApi, TTransport>; | ||
export declare function createSolanaRpcSubscriptionsFromTransport_UNSTABLE<TTransport extends RpcSubscriptionsTransport>(transport: TTransport): RpcSubscriptionsFromTransport<import("@solana/rpc-subscriptions-api").AccountNotificationsApi & import("@solana/rpc-subscriptions-api").LogsNotificationsApi & import("@solana/rpc-subscriptions-api").ProgramNotificationsApi & import("@solana/rpc-subscriptions-api").RootNotificationsApi & import("@solana/rpc-subscriptions-api").SignatureNotificationsApi & import("@solana/rpc-subscriptions-api").SlotNotificationsApi & import("@solana/rpc-subscriptions-api").BlockNotificationsApi & import("@solana/rpc-subscriptions-api").SlotsUpdatesNotificationsApi & import("@solana/rpc-subscriptions-api").VoteNotificationsApi, TTransport>; | ||
//# sourceMappingURL=rpc-subscriptions.d.ts.map |
{ | ||
"name": "@solana/rpc-subscriptions", | ||
"version": "2.0.0-experimental.e3e579c", | ||
"version": "2.0.0-experimental.e587f8d", | ||
"description": "A library for subscribing to Solana RPC notifications", | ||
@@ -50,9 +50,9 @@ "exports": { | ||
"fast-stable-stringify": "^1.0.0", | ||
"@solana/errors": "2.0.0-experimental.e3e579c", | ||
"@solana/functional": "2.0.0-experimental.e3e579c", | ||
"@solana/rpc-subscriptions-api": "2.0.0-experimental.e3e579c", | ||
"@solana/rpc-subscriptions-spec": "2.0.0-experimental.e3e579c", | ||
"@solana/rpc-subscriptions-transport-websocket": "2.0.0-experimental.e3e579c", | ||
"@solana/rpc-transformers": "2.0.0-experimental.e3e579c", | ||
"@solana/rpc-types": "2.0.0-experimental.e3e579c" | ||
"@solana/errors": "2.0.0-experimental.e587f8d", | ||
"@solana/functional": "2.0.0-experimental.e587f8d", | ||
"@solana/rpc-subscriptions-api": "2.0.0-experimental.e587f8d", | ||
"@solana/rpc-subscriptions-spec": "2.0.0-experimental.e587f8d", | ||
"@solana/rpc-subscriptions-transport-websocket": "2.0.0-experimental.e587f8d", | ||
"@solana/rpc-transformers": "2.0.0-experimental.e587f8d", | ||
"@solana/rpc-types": "2.0.0-experimental.e587f8d" | ||
}, | ||
@@ -59,0 +59,0 @@ "bundlewatch": { |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
245175
2263
+ Added@solana/addresses@2.0.0-experimental.e587f8d(transitive)
+ Added@solana/assertions@2.0.0-experimental.e587f8d(transitive)
+ Added@solana/codecs-core@2.0.0-experimental.e587f8d(transitive)
+ Added@solana/codecs-data-structures@2.0.0-experimental.e587f8d(transitive)
+ Added@solana/codecs-numbers@2.0.0-experimental.e587f8d(transitive)
+ Added@solana/codecs-strings@2.0.0-experimental.e587f8d(transitive)
+ Added@solana/errors@2.0.0-experimental.e587f8d(transitive)
+ Added@solana/functional@2.0.0-experimental.e587f8d(transitive)
+ Added@solana/keys@2.0.0-experimental.e587f8d(transitive)
+ Added@solana/rpc-spec@2.0.0-experimental.e587f8d(transitive)
+ Added@solana/rpc-spec-types@2.0.0-experimental.e587f8d(transitive)
+ Added@solana/rpc-subscriptions-api@2.0.0-experimental.e587f8d(transitive)
+ Added@solana/rpc-subscriptions-spec@2.0.0-experimental.e587f8d(transitive)
+ Added@solana/rpc-subscriptions-transport-websocket@2.0.0-experimental.e587f8d(transitive)
+ Added@solana/rpc-transformers@2.0.0-experimental.e587f8d(transitive)
+ Added@solana/rpc-types@2.0.0-experimental.e587f8d(transitive)
+ Added@solana/transactions@2.0.0-experimental.e587f8d(transitive)
- Removed@solana/addresses@2.0.0-experimental.e3e579c(transitive)
- Removed@solana/assertions@2.0.0-experimental.e3e579c(transitive)
- Removed@solana/codecs-core@2.0.0-experimental.e3e579c(transitive)
- Removed@solana/codecs-data-structures@2.0.0-experimental.e3e579c(transitive)
- Removed@solana/codecs-numbers@2.0.0-experimental.e3e579c(transitive)
- Removed@solana/codecs-strings@2.0.0-experimental.e3e579c(transitive)
- Removed@solana/errors@2.0.0-experimental.e3e579c(transitive)
- Removed@solana/functional@2.0.0-experimental.e3e579c(transitive)
- Removed@solana/keys@2.0.0-experimental.e3e579c(transitive)
- Removed@solana/rpc-spec@2.0.0-experimental.e3e579c(transitive)
- Removed@solana/rpc-spec-types@2.0.0-experimental.e3e579c(transitive)
- Removed@solana/rpc-subscriptions-api@2.0.0-experimental.e3e579c(transitive)
- Removed@solana/rpc-subscriptions-spec@2.0.0-experimental.e3e579c(transitive)
- Removed@solana/rpc-subscriptions-transport-websocket@2.0.0-experimental.e3e579c(transitive)
- Removed@solana/rpc-transformers@2.0.0-experimental.e3e579c(transitive)
- Removed@solana/rpc-types@2.0.0-experimental.e3e579c(transitive)
- Removed@solana/transactions@2.0.0-experimental.e3e579c(transitive)
Updated@solana/rpc-subscriptions-api@2.0.0-experimental.e587f8d
Updated@solana/rpc-subscriptions-spec@2.0.0-experimental.e587f8d
Updated@solana/rpc-subscriptions-transport-websocket@2.0.0-experimental.e587f8d