botframework-streaming

Streaming Connections

This feature allows you to create a named pipe server that can accept streaming connections. The code sample demonstrates how to set up a named pipe server and handle incoming connections and messages.

const { NamedPipeServer } = require('botframework-streaming');

const server = new NamedPipeServer('mypipe');
server.start();

server.on('connection', (connection) => {
  console.log('New connection established');
  connection.on('message', (message) => {
    console.log('Received message:', message);
  });
});

WebSocket Connections

This feature allows you to create a WebSocket server for streaming data. The code sample demonstrates how to set up a WebSocket server, start it, and handle incoming connections and messages.

const { WebSocketServer } = require('botframework-streaming');

const server = new WebSocketServer({ port: 8080 });
server.start();

server.on('connection', (connection) => {
  console.log('New WebSocket connection established');
  connection.on('message', (message) => {
    console.log('Received message:', message);
  });
});

Streaming Data

This feature allows you to stream data to a server. The code sample demonstrates how to create a named pipe client, connect to a server, and send a message.

const { NamedPipeClient } = require('botframework-streaming');

const client = new NamedPipeClient('mypipe');
client.connect().then(() => {
  console.log('Connected to server');
  client.send({ type: 'message', text: 'Hello, server!' });
});