Hi Sander,
Could you please explain your code a little bit
and show how to use it in my situation:
I have a component, which calls a service (to get some data or to save some
data)
and a parent container where I need to show success or failure message
or to get saved data displayed on parent container screen (refresh a grid).
So I guess I need to blend my service with yours
and inject it into component and parent container?
Please advise.
TIA,
Oleg.
On Friday, August 18, 2017 at 10:40:31 AM UTC-4, Sander Elias wrote:
>
> Hi Oleg,
>
> I deleted my previous post. the sample was riddled with typos. Should not
> be typing stuff like that without a proper editor. the next version is
> tested in a small project, to communicate between different layers of the
> application. It's the same code, but then cleaned up.
> I still don't like the idea of using DOM events, because they are not
> available anywhere outside the browser. So you can't use Angular universal
> if you do that.
>
> ok, here is a slightly better sample:
> import { Injectable } from '@angular/core';
> import { Observable } from 'rxjs/Observable';
>
> export type Payload = any;
> export interface EventBusMessage {
> channel: string;
> payload: Payload;
> }
>
> @Injectable()
> export class EventBusService {
> public listen: Observable<Payload>;
>
> private next;
> constructor() {
> this.listen = new Observable(observer => {
> this.next = (payload: Payload) => observer.next(payload);
> return _ => _ /* nothing to clean */;
> });
> this.channelEmmiter = this.channelEmmiter.bind(this);
> this.emit = this.emit.bind(this);
> }
>
> allChannels(): Observable<EventBusMessage> {
> return this.listen;
> }
>
> channel(channelName: string): Observable<Payload> {
> return this.listen
> .filter(e => e.channel === channelName)
> .map(e => e.payload);
> }
>
> channelEmmiter(channelName) {
> console.log('made listener for', channelName);
> return (payload: Payload): void =>
> this.emit({ channel: channelName, payload });
> }
>
> emit({ channel, payload }: { channel: string; payload: any }): void {
> console.log('emit', channel);
> this.next({ channel, payload });
> }
> }
>
> Regards
> Sander
>
--
You received this message because you are subscribed to the Google Groups
"Angular and AngularJS discussion" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at https://groups.google.com/group/angular.
For more options, visit https://groups.google.com/d/optout.
