Add data stream support

[lukasIO]

depends on livekit/rust-sdks#533

writing stream:

thoughts about writing: for STT we need a way to optionally also override the chunk index with this API

const greeting = 'Hi this is just a text sample';
  const streamWriter = await room.localParticipant?.streamText({
    destinationIdentities: [recipient.identity],
  });

  for (const c of greeting) {
    await streamWriter.write([c]);
// for overriding the chunk Id, you'd simply have a second value in the array like
//     await streamWriter.write([c, myChunkIndex]);

  }

  await streamWriter?.close();

reading stream:

room.on(RoomEvent.TextStreamReceived, async (reader: TextStreamReader) => 
    for await (const { current } of reader) {
      console.log(current);
    }
    // whole stream content
    console.log(await reader.readAll());
  });

[changeset-bot]

⚠️ No Changeset found

Latest commit: 957b941

Merging this PR will not cause a version bump for any packages. If these changes should not result in a new version, you're good to go. If these changes should result in a version bump, you need to add a changeset.

This PR includes no changesets

When changesets are added to this PR, you'll see the packages that this PR includes changesets for and the associated semver types

Click here to learn what changesets are, and how to add one.

Click here if you're a maintainer who wants to add a changeset to this PR

[bcherry]

Can you add docstrings to all of the exported classes? There's also at least one error handling TODO left in here still.

Looks good and thank you for including an example!

[lukasIO]

Can you add docstrings to all of the exported classes?

added some, the annoying thing however is that docstrings don't show up on class instances. And we're only returning class instances to users, so they won't really profit from them.

There's also at least one error handling TODO left in here still

errors are currently being logged to console, the TODO is in there for later improvements around re-requesting missing chunks or similar repair mechanisms. Deleted the TODOs

[lukasIO]

@theomonnom How does Rust currently handle the datachannel buffer? Do we have an event yet and/or a different mechanism for backpressure?