Skip to content

Conversation

Vinceveve
Copy link

@Vinceveve Vinceveve commented Jan 29, 2020

Try to get feedback from the handler and transfer it to the subscription
separated betweed bus and provider

send an observable to get feedback and ack or nack on subscription

bind(handler: IEventHandler<IEvent>, name: string) {
// Todo
bind(handler: IEventHandler<EventStoreEvent>, name: string) {
Copy link
Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Je ne sais pas si on peut forcer un EventStoreEvent
ça ne semble pas être un contrat de nestJS

// We've received an observable here
// let's send feedback
// TODO see how to normalize handler
run$.flatMap((event)=> defer(() => handler.handle(event)));
Copy link
Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

On va pouvoir recevoir de tout y compris un observable, a voir

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

1 participant