rsocket-websocket-client

import { RSocketClient, BufferEncoders, RSocketConnection, Payload } from 'rsocket-core'; import { RSocketWebSocketClient } from 'rsocket-websocket-client'; import { Flowable } from 'rsocket-flowable'; // For browser environments, Buffer might not be globally available. // Use TextEncoder/TextDecoder for explicit Uint8Array handling, or rely on build tool polyfills. // This example uses Buffer.from for simplicity, which works well in Node.js or with polyfills. async function connectAndInteract() { const client = new RSocketClient({ serializers: BufferEncoders, setup: { keepAlive: 60000, // Milliseconds lifetime: 180000, // Milliseconds dataMimeType: 'application/json', metadataMimeType: 'message/x.rsocket.routing.v0', // Or 'message/x.rsocket.composite-metadata.v0' }, transport: new RSocketWebSocketClient({ url: 'ws://localhost:7000/rsocket', // Replace with your RSocket server's WebSocket URL // For browser environments, explicitly provide a WebSocket constructor: wsCreator: (url) => new WebSocket(url), }), }); let rsocket: RSocketConnection | null = null; try { rsocket = await client.connect(); console.log('RSocket client connected successfully.'); // --- Request-Response interaction --- console.log('\nSending Request-Response...'); const rrPayload: Payload = { data: Buffer.from(JSON.stringify({ request: 'greeting' })), metadata: Buffer.from('hello.world'), // Simple routing key }; const rrResult = await Flowable.from<Payload>(rsocket.requestResponse(rrPayload)).first().toPromise(); console.log('Request-Response received:', rrResult.data?.toString()); // --- Request-Stream interaction --- console.log('\nSending Request-Stream...'); const rsPayload: Payload = { data: Buffer.from(JSON.stringify({ count: 3 })), metadata: Buffer.from('stream.data'), // Simple routing key }; rsocket.requestStream(rsPayload).subscribe({ onComplete: () => console.log('Request-Stream completed.'), onError: (error) => console.error('Request-Stream error:', error), onNext: (payload) => console.log('Request-Stream data:', payload.data?.toString()), onSubscribe: (subscription) => subscription.request(Infinity), // Request all available items }); // Keep the connection open for a few seconds to receive stream data await new Promise(resolve => setTimeout(resolve, 5000)); } catch (error) { console.error('Failed to connect or interact with RSocket server:', error); } finally { if (rsocket) { client.close(); console.log('RSocket client disconnected.'); } } } connectAndInteract();