Skip to content

Commit

Permalink
Add EmitWithHeadersSync emitter method
Browse files Browse the repository at this point in the history
  • Loading branch information
adw1n committed Sep 21, 2020
1 parent 3d39c5a commit c3e4062
Showing 1 changed file with 8 additions and 3 deletions.
11 changes: 8 additions & 3 deletions emitter.go
Original file line number Diff line number Diff line change
Expand Up @@ -88,13 +88,13 @@ func (e *Emitter) Emit(key string, msg interface{}) (*Promise, error) {
return e.EmitWithHeaders(key, msg, nil)
}

// EmitSync sends a message to passed topic and key.
func (e *Emitter) EmitSync(key string, msg interface{}) error {
// EmitWithHeadersSync sends a message with the given headers to passed topic and key.
func (e *Emitter) EmitWithHeadersSync(key string, msg interface{}, headers map[string][]byte) error {
var (
err error
promise *Promise
)
promise, err = e.Emit(key, msg)
promise, err = e.EmitWithHeaders(key, msg, headers)

if err != nil {
return err
Expand All @@ -109,6 +109,11 @@ func (e *Emitter) EmitSync(key string, msg interface{}) error {
return err
}

// EmitSync sends a message to passed topic and key.
func (e *Emitter) EmitSync(key string, msg interface{}) error {
return e.EmitWithHeadersSync(key, msg, nil)
}

// Finish waits until the emitter is finished producing all pending messages.
func (e *Emitter) Finish() error {
close(e.done)
Expand Down

0 comments on commit c3e4062

Please sign in to comment.