@conclurer/message-stream

Message Stream

How to Use

To use the MessageStreamService, you have to provide it in your component or module first.

import {Component} from '@angular/core';
import {MessageStreamService} from '@conclurer/message-stream';

@Component({
  providers: [
    MessageStreamService,
  ],
})
export class YourComponent {
}

MessageStreamService allows you to create one or more streams for objects. After the stream is initialized, you can listen to events or emit new messages:

import {MessageStreamService} from '@conclurer/message-stream';

export class YourComponent {
  constructor(
    private readonly messageStream: MessageStreamService,
  ) {
    const stream = this.messageStream.streamFor('YOUR OBJECT UUID');

    // Subscribes to all messages
    stream.message$.subscribe();

    // Subscribes to the ids of all subscribers of the same object
    stream.activeSubscriberIds$.subscribe();

    // Emits the given data to the server and therefor all subscribers of this object.
    stream.emit({your: 'data'});
  }
}