Implement CallbackClient

[DenisCarriere]

Changes

• Replace createPromiseClient with createCallbackClient
• Replace emitter.stop() function with CancelFn from Callback Client

Example

const cancel = emitter.start();

// Cancel after 3 seconds
setTimeout(cancel, 3000);

New event emitters

• close
• fatalError

type LocalEventTypes = {
  close: [error?: ConnectError];
  fatalError: [error: FatalError];
};

Examples

// End of Stream
emitter.on("close", (error) => {
  if (error) {
    console.error(error);
  }
});

// Fatal error
emitter.on("fatalError", (error) => {
  console.error(error);
});

[changeset-bot]

⚠️ No Changeset found

Latest commit: 88d40b9

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.

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