-
Notifications
You must be signed in to change notification settings - Fork 8
Conversation
33aecd4
to
2208622
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
noticed a tiny bug; I'll push a commit to fix it. Other than that, LGTM.
EDIT: nevermind, apparently I cannot read negative if
s.
} | ||
|
||
for _, ch := range n.sinks { | ||
ch.Send(eval) | ||
ch <- event |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
We'll soon want to handle backpressure here, but it's fine for now.
Rectified my review above; apparently I can't read code on a Friday afternoon 😛 I'll release go-libp2p-core, then update go.mod here and merge. |
typ := reflect.TypeOf(etyp) | ||
|
||
if typ.Kind() != reflect.Ptr { | ||
return nil, errors.New("subscribe called with non-pointer type") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This needs to close already created subscriptions.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
👍 yeah, since this is merged and released, could you open an issue for it?
No description provided.