refactor(experimental): refactor the default subscriptions transport with pipe to make it more readable

packages/library/package.json

@@ -66,6 +66,7 @@
     ],
     "dependencies": {
         "@solana/addresses": "workspace:*",
+        "@solana/functional": "workspace:*",
         "@solana/instructions": "workspace:*",
         "@solana/keys": "workspace:*",
         "@solana/rpc-core": "workspace:*",

packages/library/src/rpc-transport.ts

@@ -1,3 +1,4 @@
+import { pipe } from '@solana/functional';
 import { createHttpTransport } from '@solana/rpc-transport';
 import { IRpcTransport } from '@solana/rpc-transport/dist/types/transports/transport-types';
 
@@ -18,7 +19,7 @@ function normalizeHeaders<T extends Record<string, string>>(
 }
 
 export function createDefaultRpcTransport(config: Parameters<typeof createHttpTransport>[0]): IRpcTransport {
-    return getRpcTransportWithRequestCoalescing(
+    return pipe(
         createHttpTransport({
             ...config,
             headers: {
@@ -29,6 +30,6 @@ export function createDefaultRpcTransport(config: Parameters<typeof createHttpTr
                 } as { [overrideHeader: string]: string }),
             },
         }),
-        getSolanaRpcPayloadDeduplicationKey
+        transport => getRpcTransportWithRequestCoalescing(transport, getSolanaRpcPayloadDeduplicationKey)
     );
 }

packages/library/src/rpc-websocket-transport.ts

@@ -1,3 +1,4 @@
+import { pipe } from '@solana/functional';
 import { createWebSocketTransport } from '@solana/rpc-transport';
 import { IRpcWebSocketTransport } from '@solana/rpc-transport/dist/types/transports/transport-types';
 
@@ -17,17 +18,23 @@ export function createDefaultRpcSubscriptionsTransport(
     }
 ): IRpcWebSocketTransport {
     const { getShard, intervalMs, ...rest } = config;
-    return getWebSocketTransportWithAutoping({
-        intervalMs: intervalMs ?? 5_000,
-        transport: getWebSocketTransportWithConnectionSharding({
-            getShard,
-            transport: createWebSocketTransport({
-                ...rest,
-                sendBufferHighWatermark:
-                    config.sendBufferHighWatermark ??
-                    // Let 128KB of data into the WebSocket buffer before buffering it in the app.
-                    131_072,
-            }),
+    return pipe(
+        createWebSocketTransport({
+            ...rest,
+            sendBufferHighWatermark:
+                config.sendBufferHighWatermark ??
+                // Let 128KB of data into the WebSocket buffer before buffering it in the app.
+                131_072,
         }),
-    });
+        transport =>
+            getWebSocketTransportWithAutoping({
+                intervalMs: intervalMs ?? 5_000,
+                transport,
+            }),
+        transport =>
+            getWebSocketTransportWithConnectionSharding({
+                getShard,
+                transport,
+            })
+    );
 }